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 with_heartbeat_window(self, heartbeat_window: Duration) -> Self

Install the operator’s heartbeat window so the transport-loss ledger derives its budget from it (see transport_loss).

Called once at boot on the shared instance; clones made afterwards observe it because the ledger’s state is shared, and the builder replaces the whole ledger before any dispatch runs.

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.

impl Default for PendingActivities

fn default() -> PendingActivities

Returns the “default value” for a type.