Function ya_service_bus::untyped::subscribe

source · 
pub fn subscribe(
    addr: &str,
    rpc: impl RawHandler + Unpin + 'static,
    stream: impl RawStreamHandler + Unpin + 'static
) -> Handle