An accumulator of elements into a future of a result.
This is essentially a lightweight wrapper around a Sink that gets materialised to a Future, but provides convenient
methods for working directly with that future as well as transforming the input.
Provides a flow that is handled by an actor.
Utilities for Akka Streams merging and bypassing of packets.
A simple Gzip Flow
GZIPs each chunk separately.
Probes, for debugging reactive streams.