Struct LiminalTaskDelivery 

pub struct LiminalTaskDelivery { /* private fields */ }

Delivers by pushing the dispatch out on the worker’s liminal connection and blocking for the correlated reply.

The reply is the activity’s completion, so this arm re-enters it through the same completion path the gRPC transport’s out-of-band completion uses.

Implementations

impl LiminalTaskDelivery

pub fn new(completion: Arc<LiminalCompletionSource>) -> Self

Build the liminal delivery arm over the completion sink both transports share.

pub fn with_completion_tracking( self, heartbeat_tracker: HeartbeatTracker, registry: ConnectedWorkerRegistry, ) -> Self

Retire a completed dispatch from the liveness tracker when the reply lands, so this transport’s completion removes its tracked entry exactly as the gRPC session loop’s result arm does.

Required wherever the dispatcher above this arm tracks its dispatches (ActivityDispatcher::with_heartbeat_tracker). Without it the entry made before the push is never removed on this transport, and the worker’s advertised capacity is consumed permanently, one slot per delivery.

pub fn with_attempt_owners(self, attempt_owners: AttemptOwnerIndex) -> Self

Install the NOI-6 attempt-owner back-index, so a dispatched attempt binds its owning worker before the push and the intervention router can resolve the current owner of a live attempt.

Trait Implementations

impl Debug for LiminalTaskDelivery

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

Formats the value using the given formatter.

impl WorkerTaskDelivery for LiminalTaskDelivery

fn deliver<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, worker: &'life1 WorkerHandle, task: &'life2 ProtoActivityTask, intent: &'life3 SharedDeliveryIntent, accepted: &'life4 dyn DeliveryAccepted, ) -> Pin<Box<dyn Future<Output = TaskDelivery> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Deliver task to worker, awaiting whatever that transport’s notion of delivery is.