atomr-streams 0.6.0

Typed reactive streams DSL for atomr — Source / Flow / Sink, junctions, framing, kill switches, hubs, stream refs.
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71

//! atomr-streams.
//!
//! Source/Flow/Sink DSL built on top of `futures::Stream`. The surface
//! covers the linear operator set and the most common graph-DSL
//! junctions from upstream:
//!
//! * [`Source`], [`Flow`], [`Sink`] — core linear elements.
//! * [`GraphDsl`] / [`merge`], [`broadcast`], [`zip`], [`concat()`] junctions.
//! * [`Framing`] — delimiter / length-field byte framing.
//! * [`FileIO`], [`Tcp`] — I/O adapters.
//! * [`KillSwitch`] — external termination.
//! * [`RestartSource`] / [`RestartSettings`] — automatic resubscription.
//! * [`SourceQueue`] / [`Sink::queue`] — explicit backpressure handles.
//! * [`OverflowStrategy`] — bounded-buffer policies.
//! * [`BidiFlow`] — bidirectional composition.
//!
//! The port delegates pipeline execution to `futures_util::StreamExt`; each
//! combinator builds a boxed stream closure that mirrors the corresponding
//! Operator.

mod bidi;
mod file_io;
mod flow;
mod framing;
mod graph;
mod hub;
mod junction;
mod kill_switch;
mod lifecycle;
mod materializer;
mod overflow;
mod queue;
mod rate;
mod recovery;
mod restart;
mod routing;
mod runnable;
mod sink;
mod source;
mod stream_ref;
mod substream;
mod supervision;
mod tcp;
mod timed;

pub use bidi::BidiFlow;
pub use file_io::FileIO;
pub use flow::Flow;
pub use framing::{Framing, FramingError};
pub use graph::GraphDsl;
pub use hub::{BroadcastHub, MergeHub};
pub use junction::{
    broadcast, concat, merge, merge_all, merge_prioritized, merge_sorted, zip, zip_with, zip_with_index,
};
pub use kill_switch::KillSwitch;
pub use lifecycle::{count_elements, monitor, watch_termination};
pub use materializer::ActorMaterializer;
pub use overflow::OverflowStrategy;
pub use queue::{QueueOfferResult, SourceQueue};
pub use rate::{conflate, expand};
pub use recovery::{map_error, recover, recover_with, recover_with_retries, select_error};
pub use restart::{RestartSettings, RestartSource};
pub use routing::{balance, partition, unzip};
pub use runnable::RunnableGraph;
pub use sink::{Sink, SinkQueue};
pub use source::Source;
pub use stream_ref::{SinkRef, SinkRefHandle, SourceRef, SourceRefHandle};
pub use substream::{group_by, prefix_and_tail, split_after, split_when};
pub use supervision::{deciders, with_decider, Decider, SupervisionDirective};
pub use tcp::{IncomingConnection, OutgoingConnection, Tcp};
pub use timed::{grouped_within, idle_timeout, initial_delay, keep_alive};