Struct Typed 

pub struct Typed<M, Input, DecodeCodec, Inner> { /* private fields */ }

Handler produced by typed (or Typed::over for a non-decoding input kind). Override the decode-failure policy with Typed::on_decode_failure.

Implementations

impl<M, Input, DecodeCodec, Inner> Typed<M, Input, DecodeCodec, Inner>

pub fn over(codec: DecodeCodec, inner: Inner) -> Self

where Input: DecodeWith<DecodeCodec>,

Builds the adapter for any input kind: Decoded<T> decodes with codec, RawBytes ignores it (pass ()) and lends the payload itself.

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, Input, DecodeCodec, Inner> Debug for Typed<M, Input, DecodeCodec, Inner>

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

Formats the value using the given formatter.

impl<M, Input, DecodeCodec, Inner, Cx, St> Handler<M, Cx, St> for Typed<M, Input, DecodeCodec, Inner>

where M: IncomingMessage, Input: DecodeWith<DecodeCodec>, DecodeCodec: Send + Sync, Cx: Send, St: Send + Sync, Inner: Handler<Input::Target, Cx, St>,

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

Handle one input, with the per-delivery Context (carrying the broker’s typed context C and the shared application state S). The returned Settle carries the outcome the dispatcher settles by and any post-settle continuation.