Struct cocaine::dispatch::PrimitiveDispatch

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

A single-shot dispatch wraps the given oneshot sender and implements Primitive protocol emitting either value or error.

The majority of services adheres such protocol.

Methods

impl<T> PrimitiveDispatch<T>

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

Constructs a PrimitiveDispatch by wrapping the specified oneshot sender.

Trait Implementations

impl<T: Debug> Debug for PrimitiveDispatch<T>

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

Formats the value using the given formatter.

impl<T: for<'de> Deserialize<'de> + Send> Dispatch for PrimitiveDispatch<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.