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,