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
A simple Gzip Flow
A simple Gzip Flow
GZIPs each chunk separately using the JDK7 syncFlush feature.
Probes, for debugging reactive streams.
Methods to adapt Futures, Promises, Iteratees and Enumerators to and from Reactive Streams' Publishers and Subscribers.
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.