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>

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, __arg_0: &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>,
    ty: u64,
    response: &ValueRef
) -> 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.