guinea-core 0.18.0

guinea's core: actors, reducers, scopes and the event bus
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

use crate::actor::addr::Addr;
use crate::actor::event_bus::subscribe::BusSubscription;

pub trait LifecycleTracker {
    fn track_loop<T: 'static>(&self, handle: T);
    fn track_actor<A: 'static>(&self, addr: &Addr<A>);
    /// Takes ownership of a subscription, ending it at teardown.
    fn track_sub(&self, subscription: BusSubscription);

    /// Disposes the actor on shutdown.
    fn own_actor<A: 'static>(&self, addr: &Addr<A>) {
        let _ = addr;
    }
}

pub struct NullTracker;

impl LifecycleTracker for NullTracker {
    fn track_loop<T: 'static>(&self, _handle: T) {}
    fn track_actor<A: 'static>(&self, _addr: &Addr<A>) {}

    /// Nothing here owns a teardown, so the subscription is leaked rather than
    /// dropped - an untracked actor keeps receiving events, as it did before
    /// subscriptions became handles.
    fn track_sub(&self, subscription: BusSubscription) {
        subscription.leak();
    }
}