base-scheduler 0.3.0

Explicit, runtime-independent scheduler capabilities for protocol libraries
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

// Released under the MIT License.
// Copyright, 2026, by Samuel Williams.

use crate::Cancellation;
use std::sync::{Arc, mpsc};

/// A synchronous destination for a notification value.
///
/// Called in ordinary thread context, never directly in a raw signal handler. Implementations should return promptly: enqueue work or wake a future rather than waiting for it to finish. Waiting remains specific to the destination.
///
/// Channel implementations enqueue without waiting for capacity. A closed receiver discards the value. Bounded senders have no default implementation: an application must choose its own overflow policy in a wrapper.
pub trait Notify<Value>: Send + Sync {
    fn notify(&self, value: Value);
}

impl<Value> Notify<Value> for Cancellation {
    fn notify(&self, _value: Value) {
        self.cancel();
    }
}

impl<Value, Target: Notify<Value> + ?Sized> Notify<Value> for Arc<Target> {
    fn notify(&self, value: Value) {
        (**self).notify(value);
    }
}

impl<Value: Send> Notify<Value> for mpsc::Sender<Value> {
    fn notify(&self, value: Value) {
        let _ = self.send(value);
    }
}