Expand description
The linear Source/Flow/Sink DSL and the runtime that materializes it — Datum’s primary public surface, mirroring Akka/Pekko Streams Typed.
This module root owns the shared vocabulary: the BoxStream/PureTransform/
RuntimeTransform type aliases, the SourceHints/FlowHints optimization-hint
system, the fan-in stream combinators (merge_*/zip_*), the spin-then-park
constants, and the re-export block. The public types live in the submodules
(source, flow, sink, runtime, rate, time, restart, error,
completion). See this directory’s AGENTS.md for the map and the crate
CLAUDE.md for the blueprint-vs-materialization rule and execution model.
Structs§
- Aggregate
Timer - Bidi
Flow - Cancellable
- Demand
- Flow
- Keep
- Maybe
Handle - NotUsed
- Restart
Flow - Akka-style restarting flow wrapper.
- Restart
Settings - Backoff settings for
RestartSource,RestartFlow, andRestartSink. - Restart
Sink - Akka-style restarting sink wrapper.
- Restart
Source - Akka-style restarting source wrapper.
- Retry
Flow - Akka-style
RetryFlow.withBackoffhelpers. - Runnable
Graph - Runtime
- Sink
- Source
- Stream
Completion - Supervision
- Convenience constructors matching Akka’s built-in deciders.
Enums§
- Delay
Overflow Strategy - Overflow
Strategy - Sink
Combine Strategy - Source
Combine Strategy - Stream
Error - Supervision
Directive - Akka-style supervision directive for a failed user callback.
- Throttle
Mode
Traits§
- Into
Source - Converts any
IntoIteratorinto aSourceexplicitly. - Push
Outlet
Type Aliases§
- Materializer
- Stream
Result - Supervision
Decider - Shared supervision decider used by supervised operators.