Struct ContextOutboundInterceptor 

pub struct ContextOutboundInterceptor { /* private fields */ }

Outbound interceptor that captures the current dcontext and attaches it to outgoing actor messages as headers.

• Local targets: attaches a ContextSnapshotHeader only — no serialization is performed, preserving local-only context values.
• Remote targets: serializes context to bytes and attaches a ContextHeader for wire transport.

Error Handling

Controlled by ErrorPolicy:

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

Usage

use dcontext_dactor::{ContextOutboundInterceptor, ErrorPolicy};

// Default: log and continue on errors
runtime.add_outbound_interceptor(Box::new(ContextOutboundInterceptor::default()));

// Strict: reject messages if context serialization fails
runtime.add_outbound_interceptor(Box::new(
    ContextOutboundInterceptor::new(ErrorPolicy::Reject),
));

Implementations

impl ContextOutboundInterceptor

pub fn new(error_policy: ErrorPolicy) -> Self

Create with a specific error policy.

Trait Implementations

impl Default for ContextOutboundInterceptor

fn default() -> Self

Returns the “default value” for a type.

impl OutboundInterceptor for ContextOutboundInterceptor

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

Human-readable name.

fn on_send( &self, ctx: &OutboundContext<'_>, _runtime_headers: &RuntimeHeaders, headers: &mut Headers, _message: &dyn Any, ) -> Disposition

Called before the message is sent. Can modify headers, delay, reject, or retry. The message body is provided as &dyn Any for inspection.

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

Called when an ask() reply is received back on the sender side. The reply is type-erased — downcast if you know the type.

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

Called for each item flowing through a stream or feed on the sender side.