Struct ForwardCtx 

struct ForwardCtx {
    session_id: SessionId,
    draft: DraftVersion,
    draft_is_fixed: bool,
    observer: Arc<dyn ProxyObserver>,
    hook: Arc<dyn ProxyHook>,
    cancel: CancellationToken,
    observer_enabled: bool,
    control_mutation: bool,
}

Shared context for forwarding helpers, avoiding repeated parameter lists.

Fields

session_id: SessionId

draft: DraftVersion

The current best draft guess for this session. For control streams this may be refined after observing CLIENT_SETUP / SERVER_SETUP when draft_is_fixed is false.

draft_is_fixed: bool

Whether draft is fixed (from ALPN) and should not be refined by peeking at SETUP messages.

observer: Arc<dyn ProxyObserver>

hook: Arc<dyn ProxyHook>

cancel: CancellationToken

observer_enabled: bool

Cached observer.wants_events() — gates event construction and emission in the hot forwarding loop. When false, the proxy can skip parsing for observation purposes and run as a byte pump.

control_mutation: bool

Cached hook.wants_control_mutation() — when true, the control stream forwarder switches to a parse-then-forward mode that honors the hook’s Some(bytes) return. Defaults to false (pure pass-through) to avoid per-frame parsing latency.

Implementations

impl ForwardCtx

fn emit(&self, event: impl FnOnce() -> ProxyEvent)

Emit a proxy event only if the observer wants events.

Takes a closure so the ProxyEvent is not constructed when observation is disabled — avoiding clones of message payloads in the hot path.

Trait Implementations

impl Clone for ForwardCtx

fn clone(&self) -> ForwardCtx

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.