rakka-streams. akka.net: src/core/Akka.Streams.
Source/Flow/Sink DSL built on top of futures::Stream. The surface
covers the linear operator set and the most common graph-DSL
junctions from upstream:
- [
Source], [Flow], [Sink] — core linear elements. - [
graph] —merge,broadcast,zip,concatjunctions. - [
Framing] — delimiter / length-field byte framing. - [
FileIO], [Tcp] — I/O adapters. - [
KillSwitch] — external termination. - [
RestartSource] / [RestartSettings] — automatic resubscription. - [
SourceQueue] / [Sink::queue] — explicit backpressure handles. - [
OverflowStrategy] — bounded-buffer policies. - [
BidiFlow] — bidirectional composition.
The port delegates pipeline execution to futures_util::StreamExt; each
combinator builds a boxed stream closure that mirrors the corresponding
Akka.Streams operator.