Function ya_service_bus::actix_rpc::binds

pub fn binds<M: RpcStreamMessage>(
    addr: &str, 
    actor: Recipient<RpcStreamCall<M>>
) -> Handle where
    Result<M::Item, M::Error>: Serialize + DeserializeOwned + Sync + Send,