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

datum/
lib.rs
