Struct LiminalCompletionSource 

pub struct LiminalCompletionSource { /* private fields */ }

Receives one worker result over liminal and re-enters it into aion.

Holds the installed OutboxDeliveryCallback (the same prod ServerOutboxDeliveryCallback the gRPC completion path uses) and maps a DispatchResponse onto it, threading run_id so the continue-as-new run gates apply unchanged.

Implementations

impl LiminalCompletionSource

pub fn new(callback: Arc<dyn OutboxDeliveryCallback>) -> Self

Build a completion source over the shared outbox delivery callback.

pub fn with_completion_fences(self, completion_fences: CompletionFences) -> Self

Share the authoritative generation registry used by dispatch.

pub fn deliver(&self, response: &DispatchResponse) -> Result<bool, ServerError>

Re-enter one worker result into aion through the delivery callback.

Returns the callback’s bool: true when delivered to a live run, false when no run is live (the expected stale-completion drop that recovery re-arms). A success outcome routes to deliver_completion; a failure outcome to deliver_failure.

Errors

Returns ServerError when the response carries an unparseable id or the engine rejects the delivery.

Trait Implementations

impl Debug for LiminalCompletionSource

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

Formats the value using the given formatter.