act-zero 0.4.0

Ergonomic actor system
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::future::Future;

use futures::future::FutureExt;

use crate::Produces;

/// A future which completes upon termination of an actor.
#[derive(Debug)]
pub struct Termination(pub(crate) Produces<()>);

impl Future for Termination {
    type Output = ();

    fn poll(
        mut self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Self::Output> {
        self.0.poll_unpin(cx).map(|_| ())
    }
}