datum/
lib.rs

1#![forbid(unsafe_code)]
2#![doc = include_str!("../README.md")]
3
4mod attributes;
5
6pub mod actor;
7pub mod concurrent;
8pub mod context;
9pub mod dynamic;
10pub mod graph;
11pub mod io;
12pub mod queue;
13pub mod stream;
14pub mod testkit;
15
16pub use actor::{
17    ActorFlow, ActorPubSub, ActorRef, ActorSink, ActorSinkBackpressureMessage, ActorSinkMessage,
18    ActorSource, ActorSourceMessage, ActorStatus, ReplyPort, ReplySendError, SinkRef, SourceRef,
19    StreamRefFrame, StreamRefId, StreamRefMessage, StreamRefOutbound, StreamRefPayload,
20    StreamRefPayloadBatch, StreamRefPayloadBytes, StreamRefProtoConsumer, StreamRefProtoEndpoint,
21    StreamRefProtoProducer, StreamRefSettings, StreamRefs, WatchEvent,
22};
23pub use attributes::{Attribute, Attributes};
24pub use concurrent::{
25    Signal, Subscription, SubscriptionOverflow, Topic, TopicOverflow, TopicPublishError,
26    TopicTryPublishError,
27    channel::{Channel, SendError as ChannelSendError, TrySendError},
28};
29pub use context::{FlowWithContext, SourceWithContext};
30pub use dynamic::{
31    BroadcastHub, BroadcastHubConsumerSource, KillSwitches, MergeHub, MergeHubDrainingControl,
32    PartitionConsumerInfo, PartitionHub, PartitionHubConsumerSource, SharedKillSwitch,
33    UniqueKillSwitch,
34};
35pub use graph::{
36    AnyInlet, AnyOutlet, AsyncBoundary, AsyncBoundaryExecutionConfig, Balance, BidiShape,
37    Broadcast, Buffer, Concat, FanInShape, FanOutShape, FanOutShape2, FlowShape,
38    FlowShape as GraphFlowShape, FusedExecutionConfig, FusedExecutionReport, FusedTerminalReport,
39    Graph, GraphBlueprint, GraphBuilder, GraphDsl, GraphStage, GraphStageLogic, Identity,
40    ImportedGraph, InHandler, Inlet, InletCursor, Interleave, MapStage, Merge, MergeLatest,
41    MergePreferred, MergePreferredShape, MergePrioritized, MergeSequence, MergeSorted, OrElse,
42    OutHandler, Outlet, OutletCursor, PartialGraph, Partition, PortAllocator, PortId, PortKind,
43    SinkShape, SourceShape, StageSpec, TakeWhile, TimerHandler, Unzip, UnzipWith, WireDsl,
44    WirePair, WireSpec, Zip, ZipShape,
45};
46#[cfg(feature = "io-uring-file")]
47pub use io::UringFileIO;
48pub use io::{
49    Compression, FileIO, Framing, FramingByteOrder, InputStreamHandle, IoResult,
50    OutputStreamHandle, StreamConverters, TcpBinding, TcpConnection, TcpIncomingConnection,
51    TokioByteSink, TokioByteSource, TokioFileIO, TokioTcp,
52};
53pub use queue::{BoundedSourceQueue, QueueOfferResult, SinkQueue, SourceQueue};
54pub use stream::{
55    AggregateTimer, BidiFlow, Cancellable, DelayOverflowStrategy, Demand, Flow, IntoSource, Keep,
56    Materializer, MaybeHandle, NotUsed, OverflowStrategy, PushOutlet, RestartFlow, RestartSettings,
57    RestartSink, RestartSource, RetryFlow, RunnableGraph, Runtime, Sink, SinkCombineStrategy,
58    Source, SourceCombineStrategy, StreamCompletion, StreamError, StreamResult, Supervision,
59    SupervisionDecider, SupervisionDirective, ThrottleMode,
60};
61
62pub mod prelude {
63    pub use crate::{
64        AggregateTimer, AsyncBoundary, AsyncBoundaryExecutionConfig, Attributes, Balance, BidiFlow,
65        BidiShape, Broadcast, Buffer, Cancellable, Channel, ChannelSendError, Concat,
66        DelayOverflowStrategy, Demand, FanInShape, FanOutShape, FanOutShape2, Flow, FlowShape,
67        FusedExecutionConfig, FusedExecutionReport, FusedTerminalReport, Graph, GraphBlueprint,
68        GraphBuilder, GraphDsl, GraphFlowShape, Identity, ImportedGraph, Inlet, InletCursor,
69        Interleave, IntoSource, Keep, MapStage, Materializer, MaybeHandle, Merge, MergeLatest,
70        MergePreferred, MergePreferredShape, MergePrioritized, MergeSequence, MergeSorted, NotUsed,
71        OrElse, Outlet, OutletCursor, OverflowStrategy, PartialGraph, Partition, PushOutlet,
72        RestartFlow, RestartSettings, RestartSink, RestartSource, RetryFlow, RunnableGraph,
73        Runtime, Signal, Sink, SinkCombineStrategy, SinkShape, Source, SourceCombineStrategy,
74        SourceShape, StreamCompletion, StreamError, StreamResult, Subscription,
75        SubscriptionOverflow, Supervision, SupervisionDecider, SupervisionDirective, TakeWhile,
76        ThrottleMode, Topic, TopicOverflow, TopicPublishError, TopicTryPublishError, TrySendError,
77        Unzip, UnzipWith, WireDsl, WirePair, WireSpec, Zip, ZipShape,
78    };
79}
datum/lib.rs

datum/
lib.rs
