Package org.apache.pekko.stream.javadsl
package org.apache.pekko.stream.javadsl
-
ClassDescriptionFan-out the stream to several streams.Fan-out the stream to several streams.BidiFlow<I1,
O1, I2, O2, Mat> Fan-out the stream to several streams.Fan-out the stream to several streams.A BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers.A BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers.INTERNAL APIINTERNAL APITakes two streams and outputs an output stream formed from the two input streams by consuming one stream first emitting all of its elements, then consuming the second stream emitting all of its elements.Takes two streams and outputs an output stream formed from the two input streams by consuming one stream first emitting all of its elements, then consuming the second stream emitting all of its elements.Allows to manage delay and can be stateful to compute delay for any sequence of elements, all elements go through nextDelay() updating state and returning delay for each elementJava API: Factories to create sinks and sources from filesJava API: Factories 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.FlowWithContext<In,CtxIn, Out, CtxOut, Mat> A flow that provides operations which automatically propagate the context of an element.Determines mode in which [[Framing]] operates.GraphDSL.Builder<Mat>Provides support for `java.util.concurrent.Flow.*` interfaces which mirror the Reactive Streams interfaces from `org.reactivestreams`.{@link org.apache.pekko.stream.javadsl.Flow]] factories operating withjava.util.concurrent.Flow.*interfaces.Sinkfactories operating withjava.util.concurrent.Flow.*interfaces.{@link org.apache.pekko.stream.javadsl.Flow]] factories operating withjava.util.concurrent.Flow.*interfaces.Provides JSON framing operators that can separate valid JSON objects from incomingpekko.util.ByteStringobjects.Provides JSON framing operators that can separate valid JSON objects from incomingpekko.util.ByteStringobjects.Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).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.A DrainingControl object is created during the materialization of a MergeHub and allows to initiate the draining and eventual completion of the Hub from the outside.A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of producers.MergeLatest joins elements from N input streams into stream of lists of size N.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 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).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.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.Merge two pre-sorted streams such that the resulting stream is sorted.Merge two pre-sorted streams such that the resulting stream is sorted.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.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.Fan-out the stream to several streams.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.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.RunnableGraph<Mat>Java APISink<In,Mat> Java APIJava APISinkQueue<T>This trait allows to have a queue as a sink for a stream.This trait adds cancel support toSinkQueue.Source<Out,Mat> Java APIJava APISourceQueue<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<In,Out, Mat> A “stream of streams” sub-flow of data elements, e.g.SubSource<Out,Mat> A “stream of streams” sub-flow of data elements, e.g.* Upcast a stream of elements to a stream of supertypes of that element.Represents an accepted incoming TCP connection.Represents a prospective outgoing TCP connection.Represents a prospective 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.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.Split one stream into several streams using a splitting function.Split one stream into several streams using a splitting function.Fan-out the stream to two output streams - a 'main' and a 'tap' one.Fan-out the stream to two output streams - a 'main' and a 'tap' one.Combine the elements of 2 streams into a stream of tuples.Combine the elements of 2 streams into a stream of tuples.Combine the elements of 2 streams into a stream of tuples, picking always the latest element of each.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.Combine the elements of multiple streams into a stream of lists.Combine the elements of multiple streams into a stream of lists.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.Combine the elements of multiple streams into a stream of lists using a combiner function.Combine the elements of multiple streams into a stream of lists using a combiner function.