Trait RpcStreamHandler
ya_service_bus
pub trait RpcStreamHandler<T: RpcStreamMessage> { type Result: Stream<Item = Result<T::Item, T::Error>> + Unpin; fn handle(&mut self, caller: &str, msg: T) -> Self::Result; }
type Result: Stream<Item = Result<T::Item, T::Error>> + Unpin
fn handle(&mut self, caller: &str, msg: T) -> Self::Result
impl<T: RpcStreamMessage, Output: Stream<Item = Result<T::Item, T::Error>> + Unpin + 'static, F: FnMut(T) -> Output + 'static> RpcStreamHandler<T> for F
type Result = Output
fn handle(&mut self, _caller: &str, msg: T) -> Self::Result