datum/
lib.rs

1#![forbid(unsafe_code)]
2#![doc = include_str!("../README.md")]
3
4mod attributes;
5
6pub mod actor;
7pub mod context;
8pub mod dynamic;
9pub mod graph;
10pub mod io;
11pub mod queue;
12pub mod stream;
13pub mod testkit;
14
15pub use actor::{
16    ActorFlow, ActorPubSub, ActorRef, ActorSink, ActorSinkBackpressureMessage, ActorSinkMessage,
17    ActorSource, ActorSourceMessage, ActorStatus, ReplyPort, ReplySendError, SinkRef, SourceRef,
18    StreamRefSettings, StreamRefs, WatchEvent,
19};
20pub use attributes::{Attribute, Attributes};
21pub use context::{FlowWithContext, SourceWithContext};
22pub use dynamic::{
23    BroadcastHub, BroadcastHubConsumerSource, KillSwitches, MergeHub, MergeHubDrainingControl,
24    PartitionConsumerInfo, PartitionHub, PartitionHubConsumerSource, SharedKillSwitch,
25    UniqueKillSwitch,
26};
27pub use graph::{
28    AnyInlet, AnyOutlet, AsyncBoundary, AsyncBoundaryExecutionConfig, Balance, BidiShape,
29    Broadcast, Buffer, Concat, FanInShape, FanOutShape, FanOutShape2, FlowShape,
30    FlowShape as GraphFlowShape, FusedExecutionConfig, FusedExecutionReport, FusedTerminalReport,
31    Graph, GraphBlueprint, GraphBuilder, GraphDsl, GraphStage, GraphStageLogic, Identity,
32    ImportedGraph, InHandler, Inlet, Interleave, MapStage, Merge, MergeLatest, MergePreferred,
33    MergePreferredShape, MergePrioritized, MergeSequence, MergeSorted, OrElse, OutHandler, Outlet,
34    PartialGraph, Partition, PortId, PortKind, SinkShape, SourceShape, StageSpec, TakeWhile, Unzip,
35    UnzipWith, Zip, ZipShape,
36};
37pub use io::{
38    Compression, FileIO, Framing, FramingByteOrder, InputStreamHandle, IoResult,
39    OutputStreamHandle, StreamConverters, TcpBinding, TcpConnection, TcpIncomingConnection,
40    TokioByteSink, TokioByteSource, TokioFileIO, TokioTcp,
41};
42pub use queue::{BoundedSourceQueue, QueueOfferResult, SinkQueue, SourceQueue};
43pub use stream::{
44    AggregateTimer, BidiFlow, Cancellable, DelayOverflowStrategy, Demand, Flow, Keep, Materializer,
45    MaybeHandle, NotUsed, OverflowStrategy, PushOutlet, RestartFlow, RestartSettings, RestartSink,
46    RestartSource, RetryFlow, RunnableGraph, Runtime, Sink, SinkCombineStrategy, Source,
47    SourceCombineStrategy, StreamCompletion, StreamError, StreamResult, Supervision,
48    SupervisionDecider, SupervisionDirective, ThrottleMode,
49};
datum/lib.rs

datum/
lib.rs
