Function ya_service_bus::typed::bind_stream

source · 
pub fn bind_stream<T: RpcStreamMessage>(
    addr: &str,
    endpoint: impl RpcStreamHandler<T> + Unpin + 'static
) -> Handle