An accumulator of elements into a future of a result.
Provides a flow that is handled by an actor.
Provides a flow that is handled by an actor.
See https://github.com/akka/akka/issues/16985.
Utilities for Akka Streams merging and bypassing of packets.
A simple Gzip Flow
A simple Gzip Flow
GZIPs each chunk separately.
Probes, for debugging reactive streams.
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.