Trait ya_service_bus::untyped::RawStreamHandler

pub trait RawStreamHandler {
    type Result: Stream<Item = Result<ResponseChunk, Error>>;
    fn handle(&mut self, caller: &str, addr: &str, msg: &[u8]) -> Self::Result;
}

Associated Types

type Result: Stream<Item = Result<ResponseChunk, Error>>

Required methods

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

Implementations on Foreign Types

impl RawStreamHandler for ()

type Result = Pin<Box<dyn Stream<Item = Result<ResponseChunk, Error>>>>

fn handle(&mut self, _: &str, addr: &str, _: &[u8]) -> Self::Result

Implementors

impl<Output: Stream<Item = Result<ResponseChunk, Error>>, F: FnMut(&str, &str, &[u8]) -> Output + 'static> RawStreamHandler for F