| Balance<T> |
Fan-out the stream to several streams.
|
| Balance$ |
|
| BidiFlow<I1,O1,I2,O2,Mat> |
|
| BidiFlow$ |
|
| Broadcast<T> |
Fan-out the stream to several streams emitting each incoming upstream element to all downstream consumers.
|
| Broadcast$ |
|
| BroadcastHub$ |
A BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers.
|
| Compression |
|
| Compression$ |
|
| Concat<T> |
Takes multiple streams and outputs one stream formed from the input streams
by first emitting all of the elements from the first stream and then emitting
all of the elements from the second stream, etc.
|
| Concat$ |
|
| DelayStrategy$ |
|
| FileIO |
Factories to create sinks and sources from files
|
| FileIO$ |
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$ |
|
| Interleave<T> |
Interleave represents deterministic merge which takes N elements per input stream,
in-order of inputs, emits them downstream and then cycles/"wraps-around" the inputs.
|
| Interleave$ |
|
| JavaFlowSupport |
For use only with JDK 9+.
|
| JavaFlowSupport.Flow$ |
Flow factories operating with java.util.concurrent.Flow.* interfaces. |
| JavaFlowSupport.Sink$ |
Sink factories operating with java.util.concurrent.Flow.* interfaces. |
| JavaFlowSupport.Source$ |
Source factories operating with java.util.concurrent.Flow.* interfaces. |
| JavaFlowSupport$ |
For use only with JDK 9+.
|
| JsonFraming |
Provides JSON framing operators that can separate valid JSON objects from incoming ByteString objects.
|
| JsonFraming.PartialObjectException$ |
|
| JsonFraming$ |
Provides JSON framing operators that can separate valid JSON objects from incoming ByteString objects.
|
| Keep |
Convenience functions for often-encountered purposes like keeping only the
left (first) or only the right (second) of two input values.
|
| Keep$ |
Convenience functions for often-encountered purposes like keeping only the
left (first) or only the right (second) of two input values.
|
| Merge<T> |
Merge several streams, taking elements as they arrive from input streams
(picking randomly when several have elements ready).
|
| Merge$ |
|
| MergeHub$ |
A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of
producers.
|
| MergeLatest<T,M> |
|
| MergeLatest$ |
MergeLatest joins elements from N input streams into stream of lists of size N.
|
| MergePreferred<T> |
Merge several streams, taking elements as they arrive from input streams
(picking from preferred when several have elements ready).
|
| MergePreferred.MergePreferredShape<T> |
|
| MergePreferred$ |
|
| MergePrioritized<T> |
Merge several streams, taking elements as they arrive from input streams
(picking from prioritized once when several have elements ready).
|
| MergePrioritized$ |
|
| MergeSequence<T> |
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$ |
|
| MergeSorted<T> |
Merge two pre-sorted streams such that the resulting stream is sorted.
|
| OrElse$ |
|
| Partition<T> |
Fan-out the stream to several streams.
|
| Partition.PartitionOutOfBoundsException$ |
|
| Partition$ |
|
| 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. |
| RestartSourceWithContext |
A RestartSourceWithContext wraps a SourceWithContext that gets restarted when it completes or fails. |
| RestartSourceWithContext$ |
A RestartSourceWithContext wraps a SourceWithContext that gets restarted when it completes or fails. |
| RestartWithBackoffFlow<In,Out> |
|
| RestartWithBackoffFlow.Delay |
Temporary attribute that can override the time a RestartWithBackoffFlow waits
for a failure before cancelling. |
| RestartWithBackoffFlow.Delay$ |
|
| RestartWithBackoffFlow$ |
|
| RestartWithBackoffLogic<S extends Shape> |
Shared logic for all restart with backoff logics.
|
| RestartWithBackoffSink<T> |
|
| RestartWithBackoffSource<T> |
|
| RetryFlow |
|
| RetryFlow$ |
|
| RunnableGraph<Mat> |
|
| RunnableGraph$ |
|
| ScalaSessionAPI$ |
|
| Sink<In,Mat> |
A Sink is a set of stream processing steps that has one open input.
|
| Sink$ |
|
| SinkQueueWithCancel.QueueOps<T> |
|
| SinkQueueWithCancel.QueueOps$ |
|
| SinkQueueWithCancel$ |
|
| Source<Out,Mat> |
A Source is a set of stream processing steps that has one open output.
|
| Source$ |
|
| SourceQueueWithComplete.QueueOps<T> |
|
| SourceQueueWithComplete.QueueOps$ |
|
| 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.
|
| Tcp |
|
| Tcp.IncomingConnection |
Represents an accepted incoming TCP connection.
|
| Tcp.IncomingConnection$ |
|
| Tcp.OutgoingConnection |
Represents a prospective outgoing TCP connection.
|
| Tcp.OutgoingConnection$ |
|
| Tcp.ServerBinding |
Represents a successful TCP server binding.
|
| Tcp.ServerBinding$ |
|
| Tcp$ |
|
| TcpAttributes |
|
| TcpAttributes.TcpWriteBufferSize |
|
| TcpAttributes.TcpWriteBufferSize$ |
|
| TcpAttributes$ |
|
| TLS |
Stream cipher support based upon JSSE.
|
| TLS$ |
Stream cipher support based upon JSSE.
|
| TLSPlacebo |
This object holds simple wrapping BidiFlow implementations that can
be used instead of TLS when no encryption is desired. |
| TLSPlacebo$ |
This object holds simple wrapping BidiFlow implementations that can
be used instead of TLS when no encryption is desired. |
| Unzip<A,B> |
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 |
Transforms each element of input stream into multiple streams using a splitter function.
|
| UnzipWith$ |
Transforms each element of input stream into multiple streams using a splitter function.
|
| UnzipWith10<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10> |
`UnzipWith` specialized for 10 outputs
|
| UnzipWith11<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11> |
`UnzipWith` specialized for 11 outputs
|
| UnzipWith12<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12> |
`UnzipWith` specialized for 12 outputs
|
| UnzipWith13<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13> |
`UnzipWith` specialized for 13 outputs
|
| UnzipWith14<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14> |
`UnzipWith` specialized for 14 outputs
|
| UnzipWith15<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15> |
`UnzipWith` specialized for 15 outputs
|
| UnzipWith16<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16> |
`UnzipWith` specialized for 16 outputs
|
| UnzipWith17<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17> |
`UnzipWith` specialized for 17 outputs
|
| UnzipWith18<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18> |
`UnzipWith` specialized for 18 outputs
|
| UnzipWith19<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19> |
`UnzipWith` specialized for 19 outputs
|
| UnzipWith2<In,A1,A2> |
`UnzipWith` specialized for 2 outputs
|
| UnzipWith20<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20> |
`UnzipWith` specialized for 20 outputs
|
| UnzipWith21<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21> |
`UnzipWith` specialized for 21 outputs
|
| UnzipWith22<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22> |
`UnzipWith` specialized for 22 outputs
|
| UnzipWith3<In,A1,A2,A3> |
`UnzipWith` specialized for 3 outputs
|
| UnzipWith4<In,A1,A2,A3,A4> |
`UnzipWith` specialized for 4 outputs
|
| UnzipWith5<In,A1,A2,A3,A4,A5> |
`UnzipWith` specialized for 5 outputs
|
| UnzipWith6<In,A1,A2,A3,A4,A5,A6> |
`UnzipWith` specialized for 6 outputs
|
| UnzipWith7<In,A1,A2,A3,A4,A5,A6,A7> |
`UnzipWith` specialized for 7 outputs
|
| UnzipWith8<In,A1,A2,A3,A4,A5,A6,A7,A8> |
`UnzipWith` specialized for 8 outputs
|
| UnzipWith9<In,A1,A2,A3,A4,A5,A6,A7,A8,A9> |
`UnzipWith` specialized for 9 outputs
|
| UnzipWithApply.UnzipWithCreatorObject10$ |
|
| UnzipWithApply.UnzipWithCreatorObject11$ |
|
| UnzipWithApply.UnzipWithCreatorObject12$ |
|
| UnzipWithApply.UnzipWithCreatorObject13$ |
|
| UnzipWithApply.UnzipWithCreatorObject14$ |
|
| UnzipWithApply.UnzipWithCreatorObject15$ |
|
| UnzipWithApply.UnzipWithCreatorObject16$ |
|
| UnzipWithApply.UnzipWithCreatorObject17$ |
|
| UnzipWithApply.UnzipWithCreatorObject18$ |
|
| UnzipWithApply.UnzipWithCreatorObject19$ |
|
| UnzipWithApply.UnzipWithCreatorObject2$ |
|
| UnzipWithApply.UnzipWithCreatorObject20$ |
|
| UnzipWithApply.UnzipWithCreatorObject21$ |
|
| UnzipWithApply.UnzipWithCreatorObject22$ |
|
| UnzipWithApply.UnzipWithCreatorObject3$ |
|
| UnzipWithApply.UnzipWithCreatorObject4$ |
|
| UnzipWithApply.UnzipWithCreatorObject5$ |
|
| UnzipWithApply.UnzipWithCreatorObject6$ |
|
| UnzipWithApply.UnzipWithCreatorObject7$ |
|
| UnzipWithApply.UnzipWithCreatorObject8$ |
|
| UnzipWithApply.UnzipWithCreatorObject9$ |
|
| UnzipWithApply$ |
|
| WireTap$ |
|
| Zip<A,B> |
Combine the elements of 2 streams into a stream of tuples.
|
| Zip$ |
|
| ZipLatest<A,B> |
Combine the elements of 2 streams into a stream of tuples, picking always the latest element of each.
|
| ZipLatest$ |
|
| 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.
|
| ZipLatestWith10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> |
`ZipLatestWith` specialized for 10 inputs
|
| ZipLatestWith11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,O> |
`ZipLatestWith` specialized for 11 inputs
|
| ZipLatestWith12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,O> |
`ZipLatestWith` specialized for 12 inputs
|
| ZipLatestWith13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,O> |
`ZipLatestWith` specialized for 13 inputs
|
| ZipLatestWith14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,O> |
`ZipLatestWith` specialized for 14 inputs
|
| ZipLatestWith15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,O> |
`ZipLatestWith` specialized for 15 inputs
|
| ZipLatestWith16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,O> |
`ZipLatestWith` specialized for 16 inputs
|
| ZipLatestWith17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,O> |
`ZipLatestWith` specialized for 17 inputs
|
| ZipLatestWith18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,O> |
`ZipLatestWith` specialized for 18 inputs
|
| ZipLatestWith19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,O> |
`ZipLatestWith` specialized for 19 inputs
|
| ZipLatestWith2<A1,A2,O> |
`ZipLatestWith` specialized for 2 inputs
|
| ZipLatestWith20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,O> |
`ZipLatestWith` specialized for 20 inputs
|
| ZipLatestWith21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,O> |
`ZipLatestWith` specialized for 21 inputs
|
| ZipLatestWith22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22,O> |
`ZipLatestWith` specialized for 22 inputs
|
| ZipLatestWith3<A1,A2,A3,O> |
`ZipLatestWith` specialized for 3 inputs
|
| ZipLatestWith4<A1,A2,A3,A4,O> |
`ZipLatestWith` specialized for 4 inputs
|
| ZipLatestWith5<A1,A2,A3,A4,A5,O> |
`ZipLatestWith` specialized for 5 inputs
|
| ZipLatestWith6<A1,A2,A3,A4,A5,A6,O> |
`ZipLatestWith` specialized for 6 inputs
|
| ZipLatestWith7<A1,A2,A3,A4,A5,A6,A7,O> |
`ZipLatestWith` specialized for 7 inputs
|
| ZipLatestWith8<A1,A2,A3,A4,A5,A6,A7,A8,O> |
`ZipLatestWith` specialized for 8 inputs
|
| ZipLatestWith9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O> |
`ZipLatestWith` specialized for 9 inputs
|
| ZipN<A> |
Combine the elements of multiple streams into a stream of sequences.
|
| ZipN$ |
|
| 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.
|
| ZipWith10<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,O> |
`ZipWith` specialized for 10 inputs
|
| ZipWith11<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,O> |
`ZipWith` specialized for 11 inputs
|
| ZipWith12<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,O> |
`ZipWith` specialized for 12 inputs
|
| ZipWith13<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,O> |
`ZipWith` specialized for 13 inputs
|
| ZipWith14<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,O> |
`ZipWith` specialized for 14 inputs
|
| ZipWith15<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,O> |
`ZipWith` specialized for 15 inputs
|
| ZipWith16<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,O> |
`ZipWith` specialized for 16 inputs
|
| ZipWith17<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,O> |
`ZipWith` specialized for 17 inputs
|
| ZipWith18<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,O> |
`ZipWith` specialized for 18 inputs
|
| ZipWith19<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,O> |
`ZipWith` specialized for 19 inputs
|
| ZipWith2<A1,A2,O> |
`ZipWith` specialized for 2 inputs
|
| ZipWith20<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,O> |
`ZipWith` specialized for 20 inputs
|
| ZipWith21<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,O> |
`ZipWith` specialized for 21 inputs
|
| ZipWith22<A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20,A21,A22,O> |
`ZipWith` specialized for 22 inputs
|
| ZipWith3<A1,A2,A3,O> |
`ZipWith` specialized for 3 inputs
|
| ZipWith4<A1,A2,A3,A4,O> |
`ZipWith` specialized for 4 inputs
|
| ZipWith5<A1,A2,A3,A4,A5,O> |
`ZipWith` specialized for 5 inputs
|
| ZipWith6<A1,A2,A3,A4,A5,A6,O> |
`ZipWith` specialized for 6 inputs
|
| ZipWith7<A1,A2,A3,A4,A5,A6,A7,O> |
`ZipWith` specialized for 7 inputs
|
| ZipWith8<A1,A2,A3,A4,A5,A6,A7,A8,O> |
`ZipWith` specialized for 8 inputs
|
| ZipWith9<A1,A2,A3,A4,A5,A6,A7,A8,A9,O> |
`ZipWith` specialized for 9 inputs
|
| ZipWithN<A,O> |
Combine the elements of multiple streams into a stream of sequences using a combiner function.
|
| ZipWithN$ |
|