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

use crate::Actor;
use std::marker::PhantomData;

/// `Context` is used to signal things to the [`ActorManager`](trait.ActorManager.html)'s
/// management loop. Currently, it can be used to stop the actor ([`Context::stop`](struct.Context.html#method.stop)).
pub struct Context<A: Actor> {
    pub(crate) running: bool,
    phantom: PhantomData<A>, // TODO(weak_address)
}

impl<A: Actor> Context<A> {
    pub(crate) fn new() -> Self {
        Context {
            running: true,
            phantom: PhantomData,
        }
    }

    /// Stop the actor as soon as it has finished processing current message. This will mean that it
    /// will be dropped, and [`Actor::stopped`](trait.Actor.html#method.stopped) will be called.
    /// Any subsequent attempts to send messages to this actor will return the
    /// [`Disconnected`](struct.Disconnected.html) error.
    pub fn stop(&mut self) {
        self.running = false;
    }
}