bombay-rs 0.1.0

A pluggable process runtime over Bombay Behavior.
Documentation 
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
26
27
28
29
30
31

//! One task-termination edge paired with its published actor outcome.

use observe::Observation;

use super::TaskOutcome;

/// Completion of one exact running incarnation.
///
/// The Tokio task is only the temporal edge proving all task-owned resources
/// have dropped. [`TaskOutcome`] is published separately by the incarnation's
/// retirement guard, so executor join errors never become actor semantics.
pub(crate) struct Completion<T> {
    task: tokio::task::JoinHandle<()>,
    outcome: Observation<TaskOutcome<T>>,
}

impl<T> Completion<T> {
    pub(crate) const fn new(
        task: tokio::task::JoinHandle<()>,
        outcome: Observation<TaskOutcome<T>>,
    ) -> Self {
        Self { task, outcome }
    }

    pub(crate) async fn wait(self) -> TaskOutcome<T> {
        let _task_result = self.task.await;
        self.outcome
            .into_outcome()
            .expect("terminal actor task must publish one outcome before completion")
    }
}