Balance<T> |
Fan-out the stream to several streams.
|
Balance$ |
Create a new Balance with the specified number of output ports.
|
BidiFlow<I1,O1,I2,O2,Mat> |
Add the given BidiFlow as the next step in a bidirectional transformation
pipeline.
|
BidiFlow$ |
A graph with the shape of a flow logically is a flow, this method makes
it so also in type.
|
Broadcast<T> |
Fan-out the stream to several streams emitting each incoming upstream element to all downstream consumers.
|
Broadcast$ |
Create a new Broadcast with the specified number of output ports.
|
BroadcastHub<T> |
INTERNAL API
|
BroadcastHub$ |
Creates a Sink that receives elements from its upstream producer and broadcasts them to a dynamic set
of consumers.
|
Compression |
Creates a flow that gzip-compresses a stream of ByteStrings.
|
Compression$ |
Creates a flow that gzip-compresses a stream of ByteStrings.
|
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$ |
Create a new Concat .
|
CoupledTerminationBidi<I,O> |
INTERNAL API
|
CoupledTerminationFlow |
Similar to Flow.fromSinkAndSource however couples the termination of these two operators.
|
CoupledTerminationFlow$ |
Similar to Flow.fromSinkAndSource however couples the termination of these two operators.
|
FileIO |
Creates a Source from a files contents.
|
FileIO$ |
Creates a Source from a files contents.
|
Flow<In,Out,Mat> |
Connect this Flow to a Sink , concatenating the processing steps of both.
|
Flow$ |
Creates a Flow from a Reactive Streams Processor
|
FlowWithContext<In,CtxIn,Out,CtxOut,Mat> |
Context-preserving variant of akka.stream.scaladsl.Flow.withAttributes .
|
FlowWithContext$ |
Creates an "empty" FlowWithContext that passes elements through with their context unchanged.
|
Framing |
Creates a Flow that handles decoding a stream of unstructured byte chunks into a stream of frames where the
incoming chunk stream uses a specific byte-sequence to mark frame boundaries.
|
Framing$ |
Creates a Flow that handles decoding a stream of unstructured byte chunks into a stream of frames where the
incoming chunk stream uses a specific byte-sequence to mark frame boundaries.
|
GenericGraph<S extends Shape,Mat> |
INTERNAL API
|
GenericGraphWithChangedAttributes<S extends Shape,Mat> |
INTERNAL API
|
GraphDSL$ |
Creates a new Graph by importing the given graph list graphs and passing their Shape s
along with the GraphDSL.Builder to the given create function.
|
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$ |
Create a new Interleave with the specified number of input ports and given size of elements
to take from each input.
|
JsonFraming |
Returns a Flow that implements a "brace counting" based framing operator for emitting valid JSON chunks.
|
JsonFraming$ |
Returns a Flow that implements a "brace counting" based framing operator for emitting valid JSON chunks.
|
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$ |
Create a new Merge with the specified number of input ports.
|
MergeHub<T> |
INTERNAL API
|
MergeHub$ |
Creates a Source that emits elements merged from a dynamic set of producers.
|
MergeLatest<T,M> |
Create a new MergeLatest with the specified number of input ports.
|
MergeLatest$ |
Create a new MergeLatest with the specified number of input ports.
|
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$ |
Create a new MergePreferred with the specified number of secondary input ports.
|
MergePrioritized<T> |
Merge several streams, taking elements as they arrive from input streams
(picking from prioritized once when several have elements ready).
|
MergePrioritized$ |
Create a new MergePrioritized with specified number of input ports.
|
MergeSorted<T> |
Merge two pre-sorted streams such that the resulting stream is sorted.
|
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> |
Sets eagerCancel to false .
|
Partition.PartitionOutOfBoundsException$ |
|
Partition$ |
Create a new Partition operator with the specified input type.
|
PartitionHub<T> |
INTERNAL API
|
PartitionHub.Internal$ |
|
PartitionHub$ |
INTERNAL API
|
RestartFlow |
Wrap the given Flow with a Flow that will restart it when it fails or complete using an exponential
backoff.
|
RestartFlow$ |
Wrap the given Flow with a Flow that will restart it when it fails or complete using an exponential
backoff.
|
RestartSink |
Wrap the given Sink with a Sink that will restart it when it fails or complete using an exponential
backoff.
|
RestartSink$ |
Wrap the given Sink with a Sink that will restart it when it fails or complete using an exponential
backoff.
|
RestartSource |
Wrap the given Source with a Source that will restart it when it fails or complete using an exponential
backoff.
|
RestartSource$ |
Wrap the given Source with a Source that will restart it when it fails or complete using an exponential
backoff.
|
RestartWithBackoffFlow<In,Out> |
Wrap the given Flow with a Flow that will restart it when it fails using an exponential
backoff.
|
RestartWithBackoffFlow.Delay |
|
RestartWithBackoffFlow.Delay$ |
|
RestartWithBackoffFlow$ |
Temporary attribute that can override the time a RestartWithBackoffFlow waits
for a failure before cancelling.
|
RestartWithBackoffLogic<S extends Shape> |
param: out The permanent outlet
|
RestartWithBackoffSink<T> |
Wrap the given Sink with a Sink that will restart it when it fails or complete using an exponential
backoff.
|
RestartWithBackoffSource<T> |
Wrap the given Source with a Source that will restart it when it fails using an exponential backoff.
|
RunnableGraph<Mat> |
|
RunnableGraph$ |
A graph with a closed shape is logically a runnable graph, this method makes
it so also in type.
|
ScalaSessionAPI$ |
Constructs a ScalaSessionAPI instance from an SSLSession
|
Sink<In,Mat> |
Transform this Sink by applying a function to each *incoming* upstream element before
it is passed to the Sink
|
Sink$ |
INTERNAL API
|
Source<Out,Mat> |
Connect this Source to a Sink ,
concatenating the processing steps of both.
|
Source$ |
INTERNAL API
|
SourceWithContext<Out,Ctx,Mat> |
Context-preserving variant of akka.stream.scaladsl.Source.withAttributes .
|
SourceWithContext$ |
Creates a SourceWithContext from a regular source that operates on a tuple of (data, context) elements.
|
StreamConverters |
Creates a Source from an InputStream created by the given function.
|
StreamConverters$ |
Creates a Source from an InputStream created by the given function.
|
StreamRefs |
A local Sink which materializes a SourceRef which can be used by other streams (including remote ones),
to consume data from this local stream, as if they were attached directly in place of the local Sink.
|
StreamRefs$ |
A local Sink which materializes a SourceRef which can be used by other streams (including remote ones),
to consume data from this local stream, as if they were attached directly in place of the local Sink.
|
Tcp |
Creates a Tcp.ServerBinding instance which represents a prospective TCP server binding on the given endpoint .
|
Tcp.IncomingConnection |
|
Tcp.IncomingConnection$ |
|
Tcp.OutgoingConnection |
|
Tcp.OutgoingConnection$ |
|
Tcp.ServerBinding |
|
Tcp.ServerBinding$ |
|
Tcp$ |
Represents a successful TCP server binding.
|
TLS |
|
TLS$ |
|
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$ |
Create a new Unzip .
|
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<T> |
Fan-out the stream to two output streams - a 'main' and a 'tap' one.
|
WireTap$ |
|
Zip<A,B> |
Combine the elements of 2 streams into a stream of tuples.
|
Zip$ |
Create a new Zip .
|
ZipLatest<A,B> |
Combine the elements of 2 streams into a stream of tuples, picking always the latest element of each.
|
ZipLatest$ |
Create a new 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$ |
Create a new 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$ |
Create a new ZipWithN .
|