async def METHOD_NAME(
    self,
    hostname: bytes,
    port: int,
    ssl_context: Optional[SSLContext],
    timeout: TimeoutDict,
    *,
    local_address: Optional[str],
) -> AsyncSocketStream:
    connect_timeout = timeout.get("connect")
    unicode_host = hostname.decode("utf-8")
    exc_map = {
        TimeoutError: ConnectTimeout,
        OSError: ConnectError,
        BrokenResourceError: ConnectError,
    }
    with map_exceptions(exc_map):
        with anyio.fail_after(connect_timeout):
            stream: anyio.abc.ByteStream
            stream = await anyio.connect_tcp(
                unicode_host, port, local_host=local_address
            )
            if ssl_context:
                stream = await TLSStream.wrap(
                    stream,
                    hostname=unicode_host,
                    ssl_context=ssl_context,
                    standard_compatible=False,
                )
    return SocketStream(stream=stream)