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    StreamRefFrame, StreamRefId, StreamRefMessage, StreamRefPayload, StreamRefPayloadBytes,
19    StreamRefProtoConsumer, StreamRefProtoEndpoint, StreamRefProtoProducer, StreamRefSettings,
20    StreamRefs, WatchEvent,
21};
22pub use attributes::{Attribute, Attributes};
23pub use context::{FlowWithContext, SourceWithContext};
24pub use dynamic::{
25    BroadcastHub, BroadcastHubConsumerSource, KillSwitches, MergeHub, MergeHubDrainingControl,
26    PartitionConsumerInfo, PartitionHub, PartitionHubConsumerSource, SharedKillSwitch,
27    UniqueKillSwitch,
28};
29pub use graph::{
30    AnyInlet, AnyOutlet, AsyncBoundary, AsyncBoundaryExecutionConfig, Balance, BidiShape,
31    Broadcast, Buffer, Concat, FanInShape, FanOutShape, FanOutShape2, FlowShape,
32    FlowShape as GraphFlowShape, FusedExecutionConfig, FusedExecutionReport, FusedTerminalReport,
33    Graph, GraphBlueprint, GraphBuilder, GraphDsl, GraphStage, GraphStageLogic, Identity,
34    ImportedGraph, InHandler, Inlet, Interleave, MapStage, Merge, MergeLatest, MergePreferred,
35    MergePreferredShape, MergePrioritized, MergeSequence, MergeSorted, OrElse, OutHandler, Outlet,
36    PartialGraph, Partition, PortAllocator, PortId, PortKind, SinkShape, SourceShape, StageSpec,
37    TakeWhile, TimerHandler, Unzip, UnzipWith, Zip, ZipShape,
38};
39pub use io::{
40    Compression, FileIO, Framing, FramingByteOrder, InputStreamHandle, IoResult,
41    OutputStreamHandle, StreamConverters, TcpBinding, TcpConnection, TcpIncomingConnection,
42    TokioByteSink, TokioByteSource, TokioFileIO, TokioTcp,
43};
44pub use queue::{BoundedSourceQueue, QueueOfferResult, SinkQueue, SourceQueue};
45pub use stream::{
46    AggregateTimer, BidiFlow, Cancellable, DelayOverflowStrategy, Demand, Flow, Keep, Materializer,
47    MaybeHandle, NotUsed, OverflowStrategy, PushOutlet, RestartFlow, RestartSettings, RestartSink,
48    RestartSource, RetryFlow, RunnableGraph, Runtime, Sink, SinkCombineStrategy, Source,
49    SourceCombineStrategy, StreamCompletion, StreamError, StreamResult, Supervision,
50    SupervisionDecider, SupervisionDirective, ThrottleMode,
51};
datum/lib.rs

datum/
lib.rs
