Struct cocaine::dispatch::StreamingDispatch [−][src]
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>
[src]
impl<T> StreamingDispatch<T>
pub fn new(tx: UnboundedSender<Result<T, Error>>) -> Self
[src]
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>
[src]
impl<T: Debug> Debug for StreamingDispatch<T>
fn fmt(&self, f: &mut Formatter) -> Result
[src]
fn fmt(&self, f: &mut Formatter) -> Result
Formats the value using the given formatter. Read more
impl<T: for<'de> Deserialize<'de> + Send + 'static> Dispatch for StreamingDispatch<T>
[src]
impl<T: for<'de> Deserialize<'de> + Send + 'static> Dispatch for StreamingDispatch<T>
Auto Trait Implementations
impl<T> Send for StreamingDispatch<T> where
T: Send,
impl<T> Send for StreamingDispatch<T> where
T: Send,
impl<T> Sync for StreamingDispatch<T> where
T: Send,
impl<T> Sync for StreamingDispatch<T> where
T: Send,