Expand description
Core push-stream vocabulary and the first reusable Source/Flow API slice.
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§
Type Aliases§
- Materializer
- Stream
Result - Supervision
Decider - Shared supervision decider used by supervised operators.