package streams
- Alphabetic
- Public
- All
Type Members
-
sealed
trait
Accumulator[-E, +A] extends AnyRef
An accumulator of elements into a future of a result.
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.
Value Members
- object Accumulator
-
object
ActorFlow
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.
-
object
AkkaStreams
Utilities for Akka Streams merging and bypassing of packets.
-
object
GzipFlow
A simple Gzip Flow
A simple Gzip Flow
GZIPs each chunk separately.
-
object
Probes
Probes, for debugging reactive streams.