Balance |
Create a new Balance operator with the specified input type, eagerCancel is false .
|
Balance$ |
Create a new Balance operator with the specified input type, eagerCancel is false .
|
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 BidiFlow logically is a BidiFlow, this method makes
it so also in type.
|
Broadcast |
Create a new Broadcast operator with the specified input type.
|
Broadcast$ |
Create a new Broadcast operator with the specified input type.
|
BroadcastHub |
Creates a Sink that receives elements from its upstream producer and broadcasts them to a dynamic set
of consumers.
|
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 decompresses gzip-compressed stream of data.
|
Compression$ |
Creates a Flow that decompresses gzip-compressed stream of data.
|
Concat |
Create a new anonymous Concat operator with the specified input types.
|
Concat$ |
Create a new anonymous Concat operator with the specified input types.
|
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 Sink that writes incoming ByteString elements to the given file.
|
FileIO$ |
Creates a Sink that writes incoming ByteString elements to the given file.
|
Flow<In,Out,Mat> |
Converts this Flow to its Scala DSL counterpart
|
Flow$ |
Create a `Flow` which can process elements of type `T`.
|
FlowWithContext<In,CtxIn,Out,CtxOut,Mat> |
Transform this flow by the regular flow.
|
FlowWithContext$ |
Creates a FlowWithContext from a regular flow that operates on Pair elements.
|
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.
|
GraphCreate |
Creates a new Graph of the given Shape by passing a GraphDSL.Builder to the given create function.
|
GraphDSL |
|
GraphDSL.Builder<Mat> |
Import a graph into this module, performing a deep copy, discarding its
materialized value and returning the copied Ports that are now to be
connected.
|
GraphDSL$ |
|
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 |
|
Keep$ |
|
Merge |
Create a new Merge operator with the specified output type.
|
Merge$ |
Create a new Merge operator with the specified output type.
|
MergeHub |
Creates a Source that emits elements merged from a dynamic set of producers.
|
MergeHub$ |
Creates a Source that emits elements merged from a dynamic set of producers.
|
MergeLatest |
Create a new MergeLatest with the specified number of input ports.
|
MergeLatest$ |
Create a new MergeLatest with the specified number of input ports.
|
MergePreferred |
Create a new MergePreferred operator with the specified output type.
|
MergePreferred$ |
Create a new MergePreferred operator with the specified output type.
|
MergePrioritized |
Create a new MergePrioritized operator with the specified output type.
|
MergePrioritized$ |
Create a new MergePrioritized operator with the specified output type.
|
Partition |
Create a new Partition operator with the specified input type, eagerCancel is false .
|
Partition$ |
Create a new Partition operator with the specified input type, eagerCancel is false .
|
PartitionHub |
Creates a Sink that receives elements from its upstream producer and routes them to a dynamic set
of consumers.
|
PartitionHub$ |
Creates a Sink that receives elements from its upstream producer and routes them to a dynamic set
of consumers.
|
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.
|
RunnableGraph<Mat> |
Run this flow and return the materialized values of the flow.
|
RunnableGraph$ |
A graph with a closed shape is logically a runnable graph, this method makes
it so also in type.
|
Sink<In,Mat> |
Converts this Sink to its Scala DSL counterpart.
|
Sink$ |
A Sink that will invoke the given function for every received element, giving it its previous
output (or the given zero value) and the element as input.
|
Source<Out,Mat> |
Converts this Java DSL element to its Scala DSL counterpart.
|
Source$ |
Create a Source with no elements, i.e.
|
SourceWithContext<Out,Ctx,Mat> |
Transform this flow by the regular flow.
|
SourceWithContext$ |
Creates a SourceWithContext from a regular flow that operates on Pair elements.
|
StreamConverters |
Sink which writes incoming ByteString s to an OutputStream created by the given function.
|
StreamConverters$ |
Sink which writes incoming ByteString s to an OutputStream 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 in the spot of the local Sink directly.
|
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 in the spot of the local Sink directly.
|
SubFlow<In,Out,Mat> |
Converts this Flow to its Scala DSL counterpart
|
SubFlow$ |
Upcast a stream of elements to a stream of supertypes of that element.
|
SubSource<Out,Mat> |
Converts this Flow to its Scala DSL counterpart
|
SubSource$ |
* Upcast a stream of elements to a stream of supertypes of that element.
|
Tcp |
Creates a Tcp.ServerBinding instance which represents a prospective TCP server binding on the given endpoint .
|
Tcp.IncomingConnection |
|
Tcp.OutgoingConnection |
|
Tcp.ServerBinding |
|
Tcp$ |
Represents a prospective TCP server binding.
|
TLS |
Create a StreamTls BidiFlow in client mode.
|
TLS$ |
Create a StreamTls BidiFlow in client mode.
|
TLSPlacebo |
|
TLSPlacebo$ |
|
Unzip |
Creates a new Unzip operator with the specified output types.
|
Unzip$ |
Creates a new Unzip operator with the specified output types.
|
UnzipWith |
Create a new UnzipWith vertex with the specified input type and unzipping-function f .
|
UnzipWith$ |
Create a new UnzipWith vertex with the specified input type and unzipping-function f .
|
Zip |
Create a new Zip operator with the specified input types and zipping-function
which creates akka.japi.Pair s.
|
Zip$ |
Create a new Zip operator with the specified input types and zipping-function
which creates akka.japi.Pair s.
|
ZipLatest |
Create a new ZipLatest operator with the specified input types and zipping-function
which creates akka.japi.Pair s.
|
ZipLatest$ |
Create a new ZipLatest operator with the specified input types and zipping-function
which creates akka.japi.Pair s.
|
ZipLatestWith |
Create a new ZipLatestWith vertex with the specified input types and zipping-function f .
|
ZipLatestWith$ |
Create a new ZipLatestWith vertex with the specified input types and zipping-function f .
|
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 |
Create a new ZipWith vertex with the specified input types and zipping-function f .
|
ZipWith$ |
Create a new ZipWith vertex with the specified input types and zipping-function f .
|
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.
|