hannibal 0.17.3

A small actor library
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

//! # Standard Messages
//!
//! This module contains standard messages that are handled by any actor.
//!

use std::time::{Duration, Instant};

use super::{Actor, Handler, Message};

/// Ping the actor and receive the round-trip duration.
#[derive(Debug, Clone, Copy)]
pub struct Ping(Instant);
impl Message for Ping {
    type Response = Duration;
}

impl Ping {
    /// Create a new `Ping` with the current time.
    pub fn now() -> Self {
        Ping(Instant::now())
    }
}

impl<A: Actor> Handler<Ping> for A {
    async fn handle(&mut self, _ctx: &mut crate::Context<Self>, Ping(sent_time): Ping) -> Duration {
        Instant::now() - sent_time
    }
}

/// Cause the Actor's Context to garbage-collect.
///
/// see [`Context::gc`](`crate::Context::gc`) for more information.
#[derive(Debug, Clone, Copy)]
pub struct GC;
impl Message for GC {
    type Response = ();
}

impl<A: Actor> Handler<GC> for A {
    async fn handle(&mut self, ctx: &mut crate::Context<Self>, _: GC) {
        log::trace!("Garbage Collecting");
        ctx.gc();
    }
}

/// Stop the actor.
#[derive(Debug, Clone, Copy)]
pub struct Stop;
impl Message for Stop {
    type Response = crate::error::Result<()>;
}
impl<A: Actor> Handler<Stop> for A {
    async fn handle(
        &mut self,
        ctx: &mut crate::Context<Self>,
        _: Stop,
    ) -> crate::error::Result<()> {
        ctx.stop()
    }
}