Struct ContextInboundInterceptor 

pub struct ContextInboundInterceptor { /* private fields */ }

Inbound interceptor that propagates dcontext automatically through actor message handlers.

This interceptor performs two complementary actions:

1. on_receive — Normalizes context headers: if only wire bytes (ContextHeader) are present (remote hop), deserializes them into a ContextSnapshotHeader. Local snapshots are left as-is.

2. wrap_handler — Wraps the handler future with dcontext::with_context, restoring the propagated context into the async task-local scope. This makes dcontext::get_context / dcontext::set_context work automatically inside the handler — no manual with_propagated_context() call needed.

Error Handling

Controlled by ErrorPolicy:

• LogAndContinue (default) — log and deliver the message without context.
• Reject — reject the message.

Usage

use dcontext_dactor::{ContextOutboundInterceptor, ContextInboundInterceptor};

// Register interceptors — context propagation is fully automatic
runtime.add_outbound_interceptor(Box::new(ContextOutboundInterceptor::default()));
runtime.add_inbound_interceptor(Box::new(ContextInboundInterceptor::default()));

// In the handler, dcontext is available without any boilerplate:
#[async_trait]
impl Handler<MyMessage> for MyActor {
    async fn handle(&mut self, msg: MyMessage, ctx: &mut ActorContext) -> () {
        let rid: RequestId = dcontext::get_context("request_id");
        // ... context is automatically restored by the interceptor
    }
}

Implementations

impl ContextInboundInterceptor

pub fn new(error_policy: ErrorPolicy) -> Self

Create with a specific error policy.

Trait Implementations

impl Default for ContextInboundInterceptor

fn default() -> Self

Returns the “default value” for a type.

impl InboundInterceptor for ContextInboundInterceptor

fn name(&self) -> &'static str

Human-readable name for this interceptor.

fn on_receive( &self, _ctx: &InboundContext<'_>, _runtime_headers: &RuntimeHeaders, headers: &mut Headers, _message: &dyn Any, ) -> Disposition

Called before the message is delivered to the handler. The message body is provided as &dyn Any for optional downcasting.

fn wrap_handler<'a>( &'a self, _ctx: &InboundContext<'_>, headers: &Headers, ) -> Option<HandlerWrapper<'a>>

Creates a wrapper for the handler dispatch future, enabling async context that persists through handler execution.

fn on_complete( &self, _ctx: &InboundContext<'_>, _runtime_headers: &RuntimeHeaders, _headers: &Headers, _outcome: &Outcome<'_>, )

Called after the handler finishes. Called exactly once per delivered message. For ask, the Outcome::AskSuccess variant carries the type-erased reply.

fn on_expand_item( &self, ctx: &InboundContext<'_>, headers: &Headers, seq: u64, item: &(dyn Any + 'static), ) -> Disposition

Called for each item in a stream or feed.