Struct PendingActivities 

pub struct PendingActivities { /* private fields */ }

Tracks in-flight activity dispatches waiting for worker results.

When the server’s worker stream handler receives an ActivityResult, it calls complete_activity to deliver the result to the blocked NIF thread. Entries are keyed by [PendingActivityKey] so a stale result from a previous server life can never be matched to a different execution (#59).

Clones share both the pending map and the outbox-delivery callback through Arc, so set_outbox_delivery called once on any clone after construction is visible to the clone the dispatcher holds.

Implementations

impl PendingActivities

pub fn completion_fences(&self) -> CompletionFences

Share the generation registry with non-blocking outbox dispatch.

pub fn set_outbox_delivery(&self, callback: Arc<dyn OutboxDeliveryCallback>)

Install the unmatched-completion delivery callback (idempotent).

Set once, after construction, when the durable outbox is enabled. A second set is ignored and logged: the callback is process-wide and must not silently change identity.

pub fn new(heartbeat_window: Duration) -> Self

Build a sink whose transport-loss ledger derives its budget from the operator’s heartbeat window (see transport_loss).

The window is a CONSTRUCTOR parameter rather than a builder step, and that is the point: there is no way to obtain a PendingActivities without naming the window, so a wiring cannot supply everything else and silently inherit a zero budget. The previous shape — default().with_heartbeat_window(w) — was two calls where the second was omissible, and nothing in the test suite could tell the wired world from the unwired one.

pub fn lease_recorder(&self) -> LeaseRecorderSeam

The shared lease-record seam, for an outbox dispatcher built over the same pending set to record through.

pub fn set_lease_recorder( &self, recorder: Arc<dyn ActivityLeaseRecorder>, metrics: Option<Metrics>, )

Install the lease recorder once the engine exists; a duplicate install keeps the first and is logged by the seam.

pub const fn transport_losses(&self) -> &TransportLossLedger

The transport-loss ledger this sink classifies worker deaths through.

Trait Implementations

impl ActivityCompletionSink for PendingActivities

fn park_activity( &self, workflow_id: &WorkflowId, activity_id: &ActivityId, ) -> Result<(), ServerError>

Park one in-flight dispatch for restart recovery (#207): resolve the matched waiter with the ephemeral parked sentinel, and nothing else.

This resolution is MANDATORY, not an optimization: the default ActivityDispatcher::dispatch_async runs the dispatcher’s blocking std::sync::mpsc::recv() on tokio’s blocking pool, and tokio Runtime drop joins blocking threads — an unresolved waiter would wedge process exit indefinitely. An unmatched dispatch (already resolved by another path) is a no-op: a park is NEVER routed to the outbox delivery callback, because it is not a failure and must never reach a workflow.

fn complete_activity( &self, completion: ActivityCompletion, ) -> Result<(), ServerError>

Feed one worker-reported result into the engine activity contract.

impl Clone for PendingActivities

fn clone(&self) -> PendingActivities

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingActivities

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

Formats the value using the given formatter.