aion-rs 0.5.0

Transport-agnostic Aion workflow engine with durability, replay, timers, and supervision.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

//! Workflow process helpers exposed by `RuntimeHandle`.

use aion_core::{Payload, WorkflowError};

use crate::{EngineError, Pid, RuntimeHandle};

impl RuntimeHandle {
    /// Block until a workflow exits and convert its terminal runtime outcome.
    ///
    /// Normal returns become durable result payloads. Abnormal exits become typed
    /// workflow errors so lifecycle code can record a terminal failure.
    ///
    /// # Errors
    ///
    /// Returns [`EngineError::Runtime`] when the result term cannot be converted
    /// into a payload.
    pub fn workflow_outcome(
        &self,
        pid: Pid,
    ) -> Result<Result<Payload, WorkflowError>, EngineError> {
        let outcome = super::outcome::workflow_outcome(&self.scheduler, &self.atom_table, pid);
        self.release_spawn_heaps(pid);
        outcome
    }
}