Trait ya_service_bus::untyped::Fn4StreamHandlerExt

pub trait Fn4StreamHandlerExt<S>
where
    S: Stream<Item = Result<ResponseChunk, Error>>,
{
    // Required method
    fn into_stream_handler(self) -> Fn4Handler<S>;
}

Required Methods

fn into_stream_handler(self) -> Fn4Handler<S>

Implementors

impl<F, S> Fn4StreamHandlerExt<S> for F

where S: Stream<Item = Result<ResponseChunk, Error>>, F: FnMut(&str, &str, &[u8], bool) -> S + 'static,