foundation_core 0.0.6

Central crate for all foundation crates for the ewe-platform project
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

mod branches;
#[cfg(feature = "std")]
mod ctx;
mod doc;
mod drain;
mod executors;
mod extensions;
mod funcs;
mod iterators;
mod notifiers;
mod pipe;
mod pipe_mapped;
mod stream_future;
mod streams;
mod task;
mod types;
mod wake;

// modules exported as is
pub mod delayed_iterators;
pub mod multi_iterator;

// The engine entry-point macros (#[valtron] / #[valtron_test]) — defined in
// foundation_macros, re-exported here so users reach everything valtron from one
// path: `use foundation_core::valtron::{valtron_test, initialize_pool, spawn};`.
// Their expansions call `foundation_core::valtron::initialize_pool` and hold the
// returned PoolGuard until the wrapped fn exits (tokio-main style).
pub use foundation_macros::{task, timeout, valtron, valtron_test};

pub use branches::*;
#[cfg(feature = "std")]
pub use ctx::*;
pub use drain::*;
pub use executors::*;
pub use extensions::*;
pub use funcs::*;
pub use iterators::*;
pub use notifiers::*;
pub use pipe::*;
pub use pipe_mapped::*;
pub use stream_future::*;
pub use streams::*;
pub use task::*;
pub use types::*;
pub use wake::*;

// `futures_lite::StreamExt` — `.next().await`, `.collect::<Vec<_>>().await`,
// `.for_each(..).await`, … on the `futures_core::Stream` bridges returned by
// `into_next_stream()`/`into_future_stream()`. Re-exported so a consumer needs no
// separate `futures`/`futures-lite` dependency to drain a valtron stream.
#[cfg(feature = "std")]
pub use futures_lite::StreamExt;

// Re-export foundation_compact::trace so #[valtron_test] can reference
// foundation_core::valtron::trace::try_init_tracing_with() without every
// crate adding foundation_compact as a direct dependency.
pub use foundation_compact::trace;