| Interface | Description |
|---|---|
| FlowOps<Out,Mat> |
Scala API: Operations offered by Sources and Flows with a free output side: the DSL flows left-to-right only.
|
| FlowOpsMat<Out,Mat> |
INTERNAL API: this trait will be changed in binary-incompatible ways for classes that are derived from it!
Do not implement this interface outside the Akka code base!
|
| GraphApply | |
| GraphDSL.Implicits$.CombinerBase<T> | |
| GraphDSL.Implicits$.PortOps<Out> | |
| GraphDSL.Implicits$.ReverseCombinerBase<T> | |
| ScalaSessionAPI |
Allows access to an SSLSession with Scala types
|
| 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. |
| SubFlow<Out,Mat,F,C> |
A “stream of streams” sub-flow of data elements, e.g.
|
| UnzipWithApply | |
| UnzipWithApply.UnzipWithCreator<In,Out,T> | |
| UnzipWithApply.UnzipWithCreator10<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10> | |
| UnzipWithApply.UnzipWithCreator11<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11> | |
| UnzipWithApply.UnzipWithCreator12<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12> | |
| UnzipWithApply.UnzipWithCreator13<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13> | |
| UnzipWithApply.UnzipWithCreator14<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14> | |
| UnzipWithApply.UnzipWithCreator15<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15> | |
| UnzipWithApply.UnzipWithCreator16<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16> | |
| UnzipWithApply.UnzipWithCreator17<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17> | |
| UnzipWithApply.UnzipWithCreator18<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18> | |
| UnzipWithApply.UnzipWithCreator19<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19> | |
| UnzipWithApply.UnzipWithCreator2<In,A1,A2> | |
| UnzipWithApply.UnzipWithCreator20<In,A1,A2,A3,A4,A5,A6,A7,A8,A9,A10,A11,A12,A13,A14,A15,A16,A17,A18,A19,A20> | |
| UnzipWithApply.UnzipWithCreator3<In,A1,A2,A3> | |
| UnzipWithApply.UnzipWithCreator4<In,A1,A2,A3,A4> | |
| UnzipWithApply.UnzipWithCreator5<In,A1,A2,A3,A4,A5> | |
| UnzipWithApply.UnzipWithCreator6<In,A1,A2,A3,A4,A5,A6> | |
| UnzipWithApply.UnzipWithCreator7<In,A1,A2,A3,A4,A5,A6,A7> | |
| UnzipWithApply.UnzipWithCreator8<In,A1,A2,A3,A4,A5,A6,A7,A8> | |
| UnzipWithApply.UnzipWithCreator9<In,A1,A2,A3,A4,A5,A6,A7,A8,A9> | |
| ZipWithApply |
| Class | Description |
|---|---|
| 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<T> |
INTERNAL API
|
| 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$ | |
| CoupledTerminationBidi<I,O> |
INTERNAL API
|
| 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 |
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$ | |
| Framing | |
| Framing$ | |
| GraphApply.GraphImpl<S extends Shape,Mat> | |
| GraphApply$ |
INTERNAL API
|
| GraphDSL | |
| GraphDSL.Builder<M> | |
| GraphDSL.Implicits$ | |
| 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$ | |
| 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 |
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<T> |
INTERNAL API
|
| MergeHub$ |
A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of
producers.
|
| 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$ | |
| MergeSorted<T> |
Merge two pre-sorted streams such that the resulting stream is sorted.
|
| ModuleExtractor |
INTERNAL API
|
| ModuleExtractor$ |
INTERNAL API
|
| OrElse<T> |
Takes two streams and passes the first through, the secondary stream is only passed
through if the primary stream completes without passing any elements through.
|
| OrElse$ | |
| Partition<T> |
Fan-out the stream to several streams.
|
| Partition.PartitionOutOfBoundsException$ | |
| Partition$ | |
| RunnableGraph<Mat> | |
| RunnableGraph$ | |
| ScalaSessionAPI$ | |
| Sink<In,Mat> |
A
Sink is a set of stream processing steps that has one open input. |
| Sink$ | |
| Source<Out,Mat> |
A
Source is a set of stream processing steps that has one open output. |
| Source$ | |
| 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 |
| 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$ | |
| TLS |
Stream cipher support based upon JSSE.
|
| TLS$ |
Stream cipher support based upon JSSE.
|
| TLSPlacebo | |
| TLSPlacebo$ | |
| Unzip<A,B> |
Combine the elements of multiple streams into a stream of the combined elements.
|
| 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
|
| 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.UnzipWithCreatorObject3$ | |
| UnzipWithApply.UnzipWithCreatorObject4$ | |
| UnzipWithApply.UnzipWithCreatorObject5$ | |
| UnzipWithApply.UnzipWithCreatorObject6$ | |
| UnzipWithApply.UnzipWithCreatorObject7$ | |
| UnzipWithApply.UnzipWithCreatorObject8$ | |
| UnzipWithApply.UnzipWithCreatorObject9$ | |
| UnzipWithApply$ | |
| Zip<A,B> |
Combine the elements of 2 streams into a stream of tuples.
|
| Zip$ | |
| 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
|
| 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$ |
| Exception | Description |
|---|---|
| Framing.FramingException | |
| MergeHub.ProducerFailed | |
| Partition.PartitionOutOfBoundsException | |
| TcpIdleTimeoutException |