datum-core 0.9.0

Rust stream-processing library mirroring Akka/Pekko Streams Typed, built on Ractor actors
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

#![forbid(unsafe_code)]
#![doc = include_str!("../README.md")]

mod attributes;

pub mod actor;
pub mod concurrent;
pub mod context;
pub mod dynamic;
pub mod graph;
pub mod io;
pub mod queue;
pub mod stream;
pub mod testkit;

pub use actor::{
    ActorFlow, ActorPubSub, ActorRef, ActorSink, ActorSinkBackpressureMessage, ActorSinkMessage,
    ActorSource, ActorSourceMessage, ActorStatus, ReplyPort, ReplySendError, SinkRef, SourceRef,
    StreamRefFrame, StreamRefId, StreamRefMessage, StreamRefOutbound, StreamRefPayload,
    StreamRefPayloadBatch, StreamRefPayloadBytes, StreamRefProtoConsumer, StreamRefProtoEndpoint,
    StreamRefProtoProducer, StreamRefSettings, StreamRefs, WatchEvent,
};
pub use attributes::{Attribute, Attributes};
pub use concurrent::{
    Signal, Subscription, SubscriptionOverflow, Topic, TopicOverflow, TopicPublishError,
    TopicTryPublishError,
    channel::{Channel, SendError as ChannelSendError, TrySendError},
};
pub use context::{FlowWithContext, SourceWithContext};
pub use dynamic::{
    BroadcastHub, BroadcastHubConsumerSource, KillSwitches, MergeHub, MergeHubDrainingControl,
    PartitionConsumerInfo, PartitionHub, PartitionHubConsumerSource, SharedKillSwitch,
    UniqueKillSwitch,
};
pub use graph::{
    AnyInlet, AnyOutlet, AsyncBoundary, AsyncBoundaryExecutionConfig, Balance, BidiShape,
    Broadcast, Buffer, Concat, FanInShape, FanOutShape, FanOutShape2, FlowShape,
    FlowShape as GraphFlowShape, FusedExecutionConfig, FusedExecutionReport, FusedTerminalReport,
    Graph, GraphBlueprint, GraphBuilder, GraphDsl, GraphStage, GraphStageLogic, Identity,
    ImportedGraph, InHandler, Inlet, InletCursor, Interleave, MapStage, Merge, MergeLatest,
    MergePreferred, MergePreferredShape, MergePrioritized, MergeSequence, MergeSorted, OrElse,
    OutHandler, Outlet, OutletCursor, PartialGraph, Partition, PortAllocator, PortId, PortKind,
    SinkShape, SourceShape, StageSpec, TakeWhile, TimerHandler, Unzip, UnzipWith, WireDsl,
    WirePair, WireSpec, Zip, ZipShape,
};
#[cfg(feature = "io-uring-file")]
pub use io::UringFileIO;
pub use io::{
    Compression, FileIO, Framing, FramingByteOrder, InputStreamHandle, IoResult,
    OutputStreamHandle, StreamConverters, TcpBinding, TcpConnection, TcpIncomingConnection,
    TokioByteSink, TokioByteSource, TokioFileIO, TokioTcp,
};
pub use queue::{BoundedSourceQueue, QueueOfferResult, SinkQueue, SourceQueue};
pub use stream::{
    AggregateTimer, BidiFlow, Cancellable, DelayOverflowStrategy, Demand, Flow, IntoSource, Keep,
    Materializer, MaybeHandle, NotUsed, OverflowStrategy, PushOutlet, RestartFlow, RestartSettings,
    RestartSink, RestartSource, RetryFlow, RunnableGraph, Runtime, Sink, SinkCombineStrategy,
    Source, SourceCombineStrategy, StreamCompletion, StreamError, StreamResult, Supervision,
    SupervisionDecider, SupervisionDirective, ThrottleMode,
};

pub mod prelude {
    pub use crate::{
        AggregateTimer, AsyncBoundary, AsyncBoundaryExecutionConfig, Attributes, Balance, BidiFlow,
        BidiShape, Broadcast, Buffer, Cancellable, Channel, ChannelSendError, Concat,
        DelayOverflowStrategy, Demand, FanInShape, FanOutShape, FanOutShape2, Flow, FlowShape,
        FusedExecutionConfig, FusedExecutionReport, FusedTerminalReport, Graph, GraphBlueprint,
        GraphBuilder, GraphDsl, GraphFlowShape, Identity, ImportedGraph, Inlet, InletCursor,
        Interleave, IntoSource, Keep, MapStage, Materializer, MaybeHandle, Merge, MergeLatest,
        MergePreferred, MergePreferredShape, MergePrioritized, MergeSequence, MergeSorted, NotUsed,
        OrElse, Outlet, OutletCursor, OverflowStrategy, PartialGraph, Partition, PushOutlet,
        RestartFlow, RestartSettings, RestartSink, RestartSource, RetryFlow, RunnableGraph,
        Runtime, Signal, Sink, SinkCombineStrategy, SinkShape, Source, SourceCombineStrategy,
        SourceShape, StreamCompletion, StreamError, StreamResult, Subscription,
        SubscriptionOverflow, Supervision, SupervisionDecider, SupervisionDirective, TakeWhile,
        ThrottleMode, Topic, TopicOverflow, TopicPublishError, TopicTryPublishError, TrySendError,
        Unzip, UnzipWith, WireDsl, WirePair, WireSpec, Zip, ZipShape,
    };
}