Package org.apache.pekko.stream.scaladsl

Class ZipWithN<A,O>

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>

org.apache.pekko.stream.stage.GraphStage<UniformFanInShape<A,O>>

org.apache.pekko.stream.scaladsl.ZipWithN<A,O>

All Implemented Interfaces:

Graph<UniformFanInShape<A,O>,NotUsed>

Direct Known Subclasses:

ZipN

public class ZipWithN<A,O>
extends GraphStage<UniformFanInShape<A,O>>

Combine the elements of multiple streams into a stream of sequences using a combiner function.

A ZipWithN has a n input ports and one out port

'''Emits when''' all of the inputs has an element available

'''Backpressures when''' downstream backpressures

'''Completes when''' any upstream completes

'''Cancels when''' downstream cancels

Adheres to the ActorAttributes.SupervisionStrategy attribute.

If the combiner function throws and the supervision decision is pekko.stream.Supervision.Stop the stream fails. If the supervision decision is pekko.stream.Supervision.Resume or pekko.stream.Supervision.Restart the zipped element is dropped and the stream continues.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
ZipWithN(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper, int n)

Method Summary

Modifier and Type	Method	Description
static <A, O> ZipWithN<A,O>	apply(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper, int n)	Create a new ZipWithN.
GraphStageLogic	createLogic(Attributes inheritedAttributes)
Attributes	initialAttributes()
Outlet<O>	out()
UniformFanInShape<A,O>	shape()	The shape of a graph is all that is externally visible: its inlets and outlets.
String	toString()

Methods inherited from class org.apache.pekko.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.pekko.stream.Graph

addAttributes, async, async, async, getAttributes, named

Constructor Details

ZipWithN

public ZipWithN(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper,
 int n)

Method Details

apply

public static <A,
O> ZipWithN<A,O> apply(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper,
 int n)

Create a new ZipWithN.

initialAttributes

public Attributes initialAttributes()

Overrides:

initialAttributes in class GraphStageWithMaterializedValue<UniformFanInShape<A,O>,NotUsed>

shape

public UniformFanInShape<A,O> shape()

Description copied from interface: Graph

The shape of a graph is all that is externally visible: its inlets and outlets.

out

public Outlet<O> out()

createLogic

public GraphStageLogic createLogic(Attributes inheritedAttributes)

Specified by:

createLogic in class GraphStage<UniformFanInShape<A,O>>

toString

public String toString()

Overrides:

toString in class Object