Function ya_service_bus::connection::connect_with_handler[][src]

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