id_effect 0.3.0

Effect<A, E, R> (sync + async), capability DI, pipe — interpreter-style, no bundled executor
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

//! **Stratum 9 — Coordination & Communication**
//!
//! Primitives for inter-fiber communication and synchronisation, built from Strata 0–8.
//!
//! | Submodule | Provides | Depends on |
//! |-----------|----------|------------|
//! | [`deferred`] | [`Deferred`] | Stratum 6 (`runtime`), Stratum 4 (`failure`) |
//! | [`latch`] | [`Latch`] | [`deferred`] |
//! | [`queue`] | [`Queue`], [`QueueError`] | Stratum 2 (`kernel`) |
//! | [`semaphore`] | [`Semaphore`], [`Permit`] | Stratum 8 (`resource::Scope`) |
//! | [`pubsub`] | [`PubSub`] | [`queue`], Stratum 8 (`resource::Scope`) |
//! | [`channel`] | [`Channel`], [`ChannelReadError`], [`QueueChannel`] | [`queue`], Stratum 11 |
//! | [`ref_`] | [`Ref`] | Stratum 2 (`kernel`) |
//! | [`synchronized_ref`] | [`SynchronizedRef`] | Stratum 2 (`kernel`) |
//!
//! ## Public API
//!
//! Re-exported at the crate root: all public types and functions from each submodule.

pub mod channel;
pub mod deferred;
pub mod latch;
pub mod pubsub;
pub mod queue;
pub mod ref_;
pub mod request_resolver;
pub mod semaphore;
pub mod subscription_ref;
pub mod synchronized_ref;

pub use channel::{Channel, ChannelReadError, QueueChannel};
pub use deferred::Deferred;
pub use latch::Latch;
pub use pubsub::PubSub;
pub use queue::{Queue, QueueError};
pub use ref_::Ref;
pub use request_resolver::{
  FnRequestResolver, MissingKey, RequestEntry, RequestResolver, batching,
  make as make_request_resolver,
};
pub use semaphore::{Permit, Semaphore};
pub use subscription_ref::SubscriptionRef;
pub use synchronized_ref::SynchronizedRef;