Function ya_service_bus::connection::connect

pub fn connect<Transport, H>(
    client_info: ClientInfo, 
    transport: Transport
) -> ConnectionRef<Transport, H> where
    Transport: Sink<GsbMessage, Error = ProtocolError> + Stream<Item = Result<GsbMessage, ProtocolError>> + Unpin + 'static,
    H: CallRequestHandler + 'static + Default + Unpin,