Struct cocaine::dispatch::StreamingDispatch

pub struct StreamingDispatch<T> { /* fields omitted */ }

A streaming dispatch wraps the given stream and implements Streaming protocol, emitting either chunk, error or close events as usual stream events.

Methods

impl<T> StreamingDispatch<T>

pub fn new(tx: UnboundedSender<Result<T, Error>>) -> Self

Constructs a StreamingDispatch by wrapping the specified sender.

Trait Implementations

impl<T: Debug> Debug for StreamingDispatch<T>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T: for<'de> Deserialize<'de> + Send + 'static> Dispatch for StreamingDispatch<T>

fn process(self: Box<Self>, response: &Response) -> Option<Box<Dispatch>>

Processes a new incoming message from a service.

fn discard(self: Box<Self>, err: &Error)

Discards the dispatch due to some error occurred during receiving the response.