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