Function wrap_stream

async fn wrap_stream<S>(
    socket: S,
    domain: String,
    connector: Option<TlsConnector>,
    mode: Mode,
) -> Result<Stream<TokioAdapter<S>, TokioAdapter<TlsStream<S>>>, Error>
where
    S: 'static + AsyncRead + AsyncWrite + Unpin,