Package org.apache.pekko.stream.scaladsl
package org.apache.pekko.stream.scaladsl
-
ClassDescriptionBalance<T>Fan-out the stream to several streams.BidiFlow<I1,
O1, I2, O2, Mat> Broadcast<T>Fan-out the stream to several streams emitting each incoming upstream element to all downstream consumers.A BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers.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.Allows to manage delay.Factories to create sinks and sources from filesFactories to create sinks and sources from filesFlow<In,Out, Mat> AFlowis a set of stream processing steps that has one open input and one open output.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 Pekko code base!FlowWithContext<In,CtxIn, Out, CtxOut, Mat> A flow that provides operations which automatically propagate the context of an element.FlowWithContextOps<Out,Ctx, Mat> Shared stream operations forFlowWithContextandSourceWithContextthat automatically propagate a context element with each data element.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.Provides support forjava.util.concurrent.Flow.*interfaces which mirror the Reactive Streams interfaces fromorg.reactivestreams.pekko.stream.scaladsl.Flowfactories operating withjava.util.concurrent.Flow.*interfaces.pekko.stream.scaladsl.Sinkfactories operating withjava.util.concurrent.Flow.*interfaces.pekko.stream.scaladsl.Sourcefactories operating withjava.util.concurrent.Flow.*interfaces.Provides support forjava.util.concurrent.Flow.*interfaces which mirror the Reactive Streams interfaces fromorg.reactivestreams.Provides JSON framing operators that can separate valid JSON objects from incomingpekko.util.ByteStringobjects.Thrown if upstream completes with a partial object in the buffer.Provides JSON framing operators that can separate valid JSON objects from incomingpekko.util.ByteStringobjects.Convenience functions for often-encountered purposes like keeping only the left (first) or only the right (second) of two input values.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).A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of producers.MergeLatest<T,M> MergeLatest joins elements from N input streams into stream of lists of size N.Merge several streams, taking elements as they arrive from input streams (picking from preferred when several have elements ready).Merge several streams, taking elements as they arrive from input streams (picking from prioritized once when several have elements ready).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.MergeSorted<T>Merge two pre-sorted streams such that the resulting stream is sorted.Partition<T>Fan-out the stream to several streams.APartitionHubis a special streaming hub that is able to route streamed elements to a dynamic set of consumers.A RestartFlow wraps aFlowthat gets restarted when it completes or fails.A RestartFlow wraps aFlowthat gets restarted when it completes or fails.A RestartSink wraps aSinkthat gets restarted when it completes or fails.A RestartSink wraps aSinkthat gets restarted when it completes or fails.A RestartSource wraps aSourcethat gets restarted when it completes or fails.A RestartSource wraps aSourcethat gets restarted when it completes or fails.RestartWithBackoffFlow<In,Out> Temporary attribute that can override the time aRestartWithBackoffFlowwaits for a failure before cancelling.RestartWithBackoffLogic<S extends Shape>Shared logic for all restart with backoff logics.RunnableGraph<Mat>Allows access to an SSLSession with Scala typesSink<In,Mat> ASinkis a set of stream processing steps that has one open input.SinkQueue<T>This trait allows to have a queue as a sink for a stream.This trait adds cancel support toSinkQueue.Source<Out,Mat> ASourceis a set of stream processing steps that has one open output.SourceQueue<T>This trait allows to have a queue as a data source for some stream.This trait adds completion support toSourceQueue.SourceWithContext<Out,Ctx, Mat> A source that provides operations which automatically propagate the context of an element.StatefulMapConcatAccumulator<In,Out> A special accumulator forStatefulMapConcatoperator that allows to emit elements when the upstream has completed.A factory for creatingStatefulMapConcatAccumulatorinstances.Converters for interacting with the blockingjava.iostreams APIs and Java 8 StreamsConverters for interacting with the blockingjava.iostreams APIs and Java 8 StreamsFactories for creating stream refs.Factories for creating stream refs.SubFlow<Out,Mat, F, C> A “stream of streams” sub-flow of data elements, e.g.Represents an accepted incoming TCP connection.Represents a prospective outgoing TCP connection.Represents a successful TCP server binding.Stream cipher support based upon JSSE.Stream cipher support based upon JSSE.This object holds simple wrappingpekko.stream.scaladsl.BidiFlowimplementations that can be used instead ofTLSwhen no encryption is desired.This object holds simple wrappingpekko.stream.scaladsl.BidiFlowimplementations that can be used instead ofTLSwhen no encryption is desired.Unzip<A,B> Takes a stream of pair elements and splits each pair to two output streams.Takes a stream of pair elements and splits each pair to two output streams.Transforms each element of input stream into multiple streams using a splitter function.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 outputsUnzipWith11<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11> `UnzipWith` specialized for 11 outputsUnzipWith12<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12> `UnzipWith` specialized for 12 outputsUnzipWith13<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13> `UnzipWith` specialized for 13 outputsUnzipWith14<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14> `UnzipWith` specialized for 14 outputsUnzipWith15<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15> `UnzipWith` specialized for 15 outputsUnzipWith16<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16> `UnzipWith` specialized for 16 outputsUnzipWith17<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17> `UnzipWith` specialized for 17 outputsUnzipWith18<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18> `UnzipWith` specialized for 18 outputsUnzipWith19<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19> `UnzipWith` specialized for 19 outputsUnzipWith2<In,A1, A2> `UnzipWith` specialized for 2 outputsUnzipWith20<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 outputsUnzipWith21<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 outputsUnzipWith22<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 outputsUnzipWith3<In,A1, A2, A3> `UnzipWith` specialized for 3 outputsUnzipWith4<In,A1, A2, A3, A4> `UnzipWith` specialized for 4 outputsUnzipWith5<In,A1, A2, A3, A4, A5> `UnzipWith` specialized for 5 outputsUnzipWith6<In,A1, A2, A3, A4, A5, A6> `UnzipWith` specialized for 6 outputsUnzipWith7<In,A1, A2, A3, A4, A5, A6, A7> `UnzipWith` specialized for 7 outputsUnzipWith8<In,A1, A2, A3, A4, A5, A6, A7, A8> `UnzipWith` specialized for 8 outputsUnzipWith9<In,A1, A2, A3, A4, A5, A6, A7, A8, A9> `UnzipWith` specialized for 9 outputsUnzipWithApply.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.UnzipWithCreator21<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21> UnzipWithApply.UnzipWithCreator22<In,A1, A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, A20, A21, A22> 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> Zip<A,B> Combine the elements of 2 streams into a stream of tuples.ZipLatest<A,B> Combine the elements of 2 streams into a stream of tuples, picking always the latest element of each.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.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 inputsZipLatestWith11<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, O> `ZipLatestWith` specialized for 11 inputsZipLatestWith12<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, O> `ZipLatestWith` specialized for 12 inputsZipLatestWith13<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, O> `ZipLatestWith` specialized for 13 inputsZipLatestWith14<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, O> `ZipLatestWith` specialized for 14 inputsZipLatestWith15<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, O> `ZipLatestWith` specialized for 15 inputsZipLatestWith16<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, O> `ZipLatestWith` specialized for 16 inputsZipLatestWith17<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, O> `ZipLatestWith` specialized for 17 inputsZipLatestWith18<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, O> `ZipLatestWith` specialized for 18 inputsZipLatestWith19<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, O> `ZipLatestWith` specialized for 19 inputsZipLatestWith2<A1,A2, O> `ZipLatestWith` specialized for 2 inputsZipLatestWith20<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 inputsZipLatestWith21<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 inputsZipLatestWith22<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 inputsZipLatestWith3<A1,A2, A3, O> `ZipLatestWith` specialized for 3 inputsZipLatestWith4<A1,A2, A3, A4, O> `ZipLatestWith` specialized for 4 inputsZipLatestWith5<A1,A2, A3, A4, A5, O> `ZipLatestWith` specialized for 5 inputsZipLatestWith6<A1,A2, A3, A4, A5, A6, O> `ZipLatestWith` specialized for 6 inputsZipLatestWith7<A1,A2, A3, A4, A5, A6, A7, O> `ZipLatestWith` specialized for 7 inputsZipLatestWith8<A1,A2, A3, A4, A5, A6, A7, A8, O> `ZipLatestWith` specialized for 8 inputsZipLatestWith9<A1,A2, A3, A4, A5, A6, A7, A8, A9, O> `ZipLatestWith` specialized for 9 inputsZipN<A>Combine the elements of multiple streams into a stream of sequences.Combine the elements of multiple streams into a stream of combined elements using a combiner function.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 inputsZipWith11<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, O> `ZipWith` specialized for 11 inputsZipWith12<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, O> `ZipWith` specialized for 12 inputsZipWith13<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, O> `ZipWith` specialized for 13 inputsZipWith14<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, O> `ZipWith` specialized for 14 inputsZipWith15<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, O> `ZipWith` specialized for 15 inputsZipWith16<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, O> `ZipWith` specialized for 16 inputsZipWith17<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, O> `ZipWith` specialized for 17 inputsZipWith18<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, O> `ZipWith` specialized for 18 inputsZipWith19<A1,A2, A3, A4, A5, A6, A7, A8, A9, A10, A11, A12, A13, A14, A15, A16, A17, A18, A19, O> `ZipWith` specialized for 19 inputsZipWith2<A1,A2, O> `ZipWith` specialized for 2 inputsZipWith20<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 inputsZipWith21<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 inputsZipWith22<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 inputsZipWith3<A1,A2, A3, O> `ZipWith` specialized for 3 inputsZipWith4<A1,A2, A3, A4, O> `ZipWith` specialized for 4 inputsZipWith5<A1,A2, A3, A4, A5, O> `ZipWith` specialized for 5 inputsZipWith6<A1,A2, A3, A4, A5, A6, O> `ZipWith` specialized for 6 inputsZipWith7<A1,A2, A3, A4, A5, A6, A7, O> `ZipWith` specialized for 7 inputsZipWith8<A1,A2, A3, A4, A5, A6, A7, A8, O> `ZipWith` specialized for 8 inputsZipWith9<A1,A2, A3, A4, A5, A6, A7, A8, A9, O> `ZipWith` specialized for 9 inputsZipWithN<A,O> Combine the elements of multiple streams into a stream of sequences using a combiner function.