Trait ya_service_bus::RpcStreamHandler[−][src]

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;
}

Associated Types

type Result: Stream<Item = Result<T::Item, T::Error>> + Unpin[src]

Required methods

fn handle(&mut self, caller: &str, msg: T) -> Self::Result[src]

Implementors

impl<T: RpcStreamMessage, Output: Stream<Item = Result<T::Item, T::Error>> + Unpin + 'static, F: FnMut(T) -> Output + 'static> RpcStreamHandler<T> for F[src]

type Result = Output

fn handle(&mut self, _caller: &str, msg: T) -> Self::Result[src]