| Balance |
Fan-out the stream to several streams.
|
| Balance$ |
Fan-out the stream to several streams.
|
| BidiFlow<I1,O1,I2,O2,Mat> |
|
| BidiFlow$ |
|
| Broadcast |
Fan-out the stream to several streams.
|
| Broadcast$ |
Fan-out the stream to several streams.
|
| BroadcastHub |
A BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers.
|
| BroadcastHub$ |
A BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers.
|
| Compression |
|
| Compression$ |
|
| Concat |
Takes two streams and outputs an output stream formed from the two input streams
by consuming one stream first emitting all of its elements, then consuming the
second stream emitting all of its elements.
|
| Concat$ |
Takes two streams and outputs an output stream formed from the two input streams
by consuming one stream first emitting all of its elements, then consuming the
second stream emitting all of its elements.
|
| CoupledTerminationFlow |
Allows coupling termination (cancellation, completion, erroring) of Sinks and Sources while creating a Flow from them.
|
| CoupledTerminationFlow$ |
Allows coupling termination (cancellation, completion, erroring) of Sinks and Sources while creating a Flow from them.
|
| DelayStrategy$ |
|
| FileIO |
Java API: Factories to create sinks and sources from files
|
| FileIO$ |
Java API: Factories to create sinks and sources from files
|
| Flow<In,Out,Mat> |
A Flow is a set of stream processing steps that has one open input and one open output.
|
| Flow$ |
|
| FlowWithContext<In,CtxIn,Out,CtxOut,Mat> |
A flow that provides operations which automatically propagate the context of an element.
|
| FlowWithContext$ |
|
| Framing |
|
| Framing$ |
|
| GraphDSL |
|
| GraphDSL.Builder<Mat> |
|
| GraphDSL$ |
|
| JsonFraming |
Provides JSON framing operators that can separate valid JSON objects from incoming pekko.util.ByteString objects.
|
| JsonFraming$ |
Provides JSON framing operators that can separate valid JSON objects from incoming pekko.util.ByteString objects.
|
| Keep |
|
| Keep$ |
|
| Merge |
Merge several streams, taking elements as they arrive from input streams
(picking randomly when several have elements ready).
|
| Merge$ |
Merge several streams, taking elements as they arrive from input streams
(picking randomly when several have elements ready).
|
| MergeHub |
A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of
producers.
|
| MergeHub$ |
A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of
producers.
|
| MergeLatest |
MergeLatest joins elements from N input streams into stream of lists of size N.
|
| MergeLatest$ |
MergeLatest joins elements from N input streams into stream of lists of size N.
|
| MergePreferred |
Merge several streams, taking elements as they arrive from input streams
(picking from preferred when several have elements ready).
|
| MergePreferred$ |
Merge several streams, taking elements as they arrive from input streams
(picking from preferred when several have elements ready).
|
| MergePrioritized |
Merge several streams, taking elements as they arrive from input streams
(picking from prioritized once when several have elements ready).
|
| MergePrioritized$ |
Merge several streams, taking elements as they arrive from input streams
(picking from prioritized once when several have elements ready).
|
| MergeSequence |
Takes multiple streams whose elements in aggregate have a defined linear
sequence with difference 1, starting at 0, and outputs a single stream
containing these elements, in order.
|
| MergeSequence$ |
Takes multiple streams whose elements in aggregate have a defined linear
sequence with difference 1, starting at 0, and outputs a single stream
containing these elements, in order.
|
| Partition |
Fan-out the stream to several streams.
|
| Partition$ |
Fan-out the stream to several streams.
|
| PartitionHub |
A PartitionHub is a special streaming hub that is able to route streamed elements to a dynamic set of consumers.
|
| PartitionHub$ |
A PartitionHub is a special streaming hub that is able to route streamed elements to a dynamic set of consumers.
|
| RestartFlow |
A RestartFlow wraps a Flow that gets restarted when it completes or fails. |
| RestartFlow$ |
A RestartFlow wraps a Flow that gets restarted when it completes or fails. |
| RestartSink |
A RestartSink wraps a Sink that gets restarted when it completes or fails. |
| RestartSink$ |
A RestartSink wraps a Sink that gets restarted when it completes or fails. |
| RestartSource |
A RestartSource wraps a Source that gets restarted when it completes or fails. |
| RestartSource$ |
A RestartSource wraps a Source that gets restarted when it completes or fails. |
| RetryFlow |
|
| RetryFlow$ |
|
| RunnableGraph<Mat> |
Java API
|
| RunnableGraph$ |
|
| Sink<In,Mat> |
Java API
|
| Sink$ |
Java API
|
| SinkQueueWithCancel$ |
|
| Source<Out,Mat> |
Java API
|
| Source$ |
Java API
|
| SourceQueueWithComplete$ |
|
| SourceWithContext<Out,Ctx,Mat> |
A source that provides operations which automatically propagate the context of an element.
|
| SourceWithContext$ |
|
| StreamConverters |
Converters for interacting with the blocking java.io streams APIs and Java 8 Streams
|
| StreamConverters$ |
Converters for interacting with the blocking java.io streams APIs and Java 8 Streams
|
| StreamRefs |
Factories for creating stream refs.
|
| StreamRefs$ |
Factories for creating stream refs.
|
| SubFlow<In,Out,Mat> |
A “stream of streams” sub-flow of data elements, e.g.
|
| SubFlow$ |
|
| SubSource<Out,Mat> |
A “stream of streams” sub-flow of data elements, e.g.
|
| SubSource$ |
* Upcast a stream of elements to a stream of supertypes of that element.
|
| Tcp |
|
| Tcp.IncomingConnection |
Represents an accepted incoming TCP connection.
|
| Tcp.OutgoingConnection |
Represents a prospective outgoing TCP connection.
|
| Tcp.ServerBinding |
Represents a prospective TCP server binding.
|
| Tcp$ |
|
| TLS |
Stream cipher support based upon JSSE.
|
| TLS$ |
Stream cipher support based upon JSSE.
|
| TLSPlacebo |
This object holds simple wrapping pekko.stream.scaladsl.BidiFlow implementations that can
be used instead of TLS when no encryption is desired. |
| TLSPlacebo$ |
This object holds simple wrapping pekko.stream.scaladsl.BidiFlow implementations that can
be used instead of TLS when no encryption is desired. |
| Unzip |
Takes a stream of pair elements and splits each pair to two output streams.
|
| Unzip$ |
Takes a stream of pair elements and splits each pair to two output streams.
|
| UnzipWith |
Split one stream into several streams using a splitting function.
|
| UnzipWith$ |
Split one stream into several streams using a splitting function.
|
| Zip |
Combine the elements of 2 streams into a stream of tuples.
|
| Zip$ |
Combine the elements of 2 streams into a stream of tuples.
|
| ZipLatest |
Combine the elements of 2 streams into a stream of tuples, picking always the latest element of each.
|
| ZipLatest$ |
Combine the elements of 2 streams into a stream of tuples, picking always the latest element of each.
|
| ZipLatestWith |
Combine the elements of multiple streams into a stream of combined elements using a combiner function,
picking always the latest of the elements of each source.
|
| ZipLatestWith$ |
Combine the elements of multiple streams into a stream of combined elements using a combiner function,
picking always the latest of the elements of each source.
|
| ZipN |
Combine the elements of multiple streams into a stream of lists.
|
| ZipN$ |
Combine the elements of multiple streams into a stream of lists.
|
| ZipWith |
Combine the elements of multiple streams into a stream of combined elements using a combiner function.
|
| ZipWith$ |
Combine the elements of multiple streams into a stream of combined elements using a combiner function.
|
| ZipWithN |
Combine the elements of multiple streams into a stream of lists using a combiner function.
|
| ZipWithN$ |
Combine the elements of multiple streams into a stream of lists using a combiner function.
|