Package org.apache.pekko.stream.scaladsl

Class ZipLatest<A,B>

java.lang.Object

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

org.apache.pekko.stream.stage.GraphStage<FanInShape2<A1,A2,O>>

org.apache.pekko.stream.scaladsl.ZipLatestWith2<A,B,scala.Tuple2<A,B>>

org.apache.pekko.stream.scaladsl.ZipLatest<A,B>

All Implemented Interfaces:

Graph<FanInShape2<A,B,scala.Tuple2<A,B>>,NotUsed>

public final class ZipLatest<A,B>
extends ZipLatestWith2<A,B,scala.Tuple2<A,B>>

Combine the elements of 2 streams into a stream of tuples, picking always the latest element of each.

A ZipLatest has a left and a right input port and one out port.

No element is emitted until at least one element from each Source becomes available.

'''Emits when''' all of the inputs have at least an element available, and then each time an element becomes * available on either of the inputs

'''Backpressures when''' downstream backpressures

'''Completes when''' any upstream completes if eagerComplete is enabled or wait for all upstreams to complete

'''Cancels when''' downstream cancels

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
ZipLatest()
ZipLatest(boolean eagerComplete)

Method Summary

Modifier and Type	Method	Description
static <A, B> ZipLatest<A,B>	apply()	Create a new ZipLatest.
static <A, B> ZipLatest<A,B>	apply(boolean eagerComplete)	Create a new ZipLatest.
String	toString()

Methods inherited from class org.apache.pekko.stream.scaladsl.ZipLatestWith2

createLogic, eagerComplete, in0, in1, initialAttributes, out, shape, zipper

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

ZipLatest

public ZipLatest(boolean eagerComplete)

ZipLatest

public ZipLatest()

Method Details

apply

public static <A,
B> ZipLatest<A,B> apply()

Create a new ZipLatest.

apply

public static <A,
B> ZipLatest<A,B> apply(boolean eagerComplete)

Create a new ZipLatest.

toString

public String toString()

Overrides:

toString in class ZipLatestWith2<A,B,scala.Tuple2<A,B>>