compio-actor 0.1.0

Actors for Compio
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use std::{
    error::Error,
    fmt,
    future::Future,
    pin::Pin,
    task::{Context, Poll},
};

use futures_channel::oneshot;

/// The observed result of an actor task.
#[derive(Debug, PartialEq, Eq)]
pub enum ActorExit<E: Send + 'static> {
    /// The actor stopped normally.
    Stopped,
    /// A lifecycle method failed.
    Failed(E),
}

/// The worker stopped before reporting an actor's exit.
#[derive(Debug, PartialEq, Eq)]
pub struct ActorHandleError;

impl fmt::Display for ActorHandleError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str("actor worker stopped before reporting an exit")
    }
}

impl Error for ActorHandleError {}

/// A handle for observing an actor running in the cluster.
pub struct ActorHandle<E: Send + 'static> {
    pub(crate) result: oneshot::Receiver<Result<ActorExit<E>, ()>>,
}

impl<E: Send + 'static> Future for ActorHandle<E> {
    type Output = Result<ActorExit<E>, ActorHandleError>;

    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
        Pin::new(&mut self.get_mut().result)
            .poll(cx)
            .map(|result| result.ok().and_then(Result::ok).ok_or(ActorHandleError))
    }
}