Struct Typed 

pub struct Typed<M, T, C, H> { /* private fields */ }

Handler produced by typed. Override the decode-failure policy with Typed::on_decode_failure.

Implementations

impl<M, T, C, H> Typed<M, T, C, H>

pub fn on_decode_failure(self, decode: FailurePolicy) -> Self

Sets the FailurePolicy applied when the codec fails to decode an incoming payload. The default is FailurePolicy::Drop.

Trait Implementations

impl<M, T, C, H> Debug for Typed<M, T, C, H>

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

Formats the value using the given formatter.

impl<M, T, C, H> Handler<M> for Typed<M, T, C, H>

where M: IncomingMessage, T: DeserializeOwned + Send + Sync, C: Codec, H: Handler<T>,

async fn handle(&self, msg: &M, ctx: &mut Context<'_>) -> Settle

Handle one input, with the per-delivery Context. The returned Settle carries the outcome the dispatcher settles by and any post-settle continuation.