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, StreamRefOutbound, StreamRefPayload,
19    StreamRefPayloadBatch, StreamRefPayloadBytes, StreamRefProtoConsumer, StreamRefProtoEndpoint,
20    StreamRefProtoProducer, StreamRefSettings, 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};
39#[cfg(feature = "io-uring-file")]
40pub use io::UringFileIO;
41pub use io::{
42    Compression, FileIO, Framing, FramingByteOrder, InputStreamHandle, IoResult,
43    OutputStreamHandle, StreamConverters, TcpBinding, TcpConnection, TcpIncomingConnection,
44    TokioByteSink, TokioByteSource, TokioFileIO, TokioTcp,
45};
46pub use queue::{BoundedSourceQueue, QueueOfferResult, SinkQueue, SourceQueue};
47pub use stream::{
48    AggregateTimer, BidiFlow, Cancellable, DelayOverflowStrategy, Demand, Flow, Keep, Materializer,
49    MaybeHandle, NotUsed, OverflowStrategy, PushOutlet, RestartFlow, RestartSettings, RestartSink,
50    RestartSource, RetryFlow, RunnableGraph, Runtime, Sink, SinkCombineStrategy, Source,
51    SourceCombineStrategy, StreamCompletion, StreamError, StreamResult, Supervision,
52    SupervisionDecider, SupervisionDirective, ThrottleMode,
53};
datum/lib.rs

datum/
lib.rs
