| Interface | Description |
|---|---|
| SinkQueue<T> |
Trait allows to have the queue as a sink for some stream.
|
| SinkQueueWithCancel<T> |
This trait adds cancel support to
SinkQueue. |
| SourceQueue<T> |
This trait allows to have the queue as a data source for some stream.
|
| SourceQueueWithComplete<T> |
This trait adds completion support to
SourceQueue. |
| Class | Description |
|---|---|
| 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 them them.
|
| CoupledTerminationFlow$ |
Allows coupling termination (cancellation, completion, erroring) of Sinks and Sources while creating a Flow them them.
|
| FileIO |
Factories to create sinks and sources from files
|
| FileIO$ |
Factories to create sinks and sources from files
|
| Flow<In,Out,Mat> |
Create a `Flow` which can process elements of type `T`.
|
| Flow$ | |
| Framing | |
| Framing$ | |
| GraphCreate | |
| GraphDSL | |
| GraphDSL.Builder<Mat> | |
| GraphDSL$ | |
| JsonFraming |
Provides JSON framing stages that can separate valid JSON objects from incoming
ByteString objects. |
| JsonFraming$ |
Provides JSON framing stages that can separate valid JSON objects from incoming
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.
|
| 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).
|
| Partition |
Fan-out the stream to several streams.
|
| Partition$ |
Fan-out the stream to several streams.
|
| RunnableGraph<Mat> |
Java API
|
| RunnableGraph$ | |
| Sink<In,Mat> |
Java API
|
| Sink$ |
Java API
|
| Source<Out,Mat> |
Java API
|
| Source$ |
Java API
|
| 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 |
| SubFlow<In,Out,Mat> |
A “stream of streams” sub-flow of data elements, e.g.
|
| SubSource<Out,Mat> |
A “stream of streams” sub-flow of data elements, e.g.
|
| 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 | |
| TLSPlacebo$ | |
| 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.
|
| 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.
|
| Enum | Description |
|---|---|
| AsPublisher | |
| FramingTruncation |
Determines mode in which [[Framing]] operates.
|