Package org.apache.pekko.stream.javadsl

Class ZipLatest$

java.lang.Object

org.apache.pekko.stream.javadsl.ZipLatest$

public class ZipLatest$
extends Object

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

A Zip has a left and a right input port and one out port

'''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

'''Cancels when''' downstream cancels

Field Summary

Fields

Modifier and Type	Field	Description
static final ZipLatest$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
ZipLatest$()

Method Summary

Modifier and Type	Method	Description
<A, B> Graph<FanInShape2<A,B,Pair<A,B>>,NotUsed>	create()	Create a new ZipLatest operator with the specified input types and zipping-function which creates org.apache.pekko.japi.Pairs.

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final ZipLatest$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ZipLatest$

public ZipLatest$()

Method Details

create

public <A,
B>
Graph<FanInShape2<A,B,Pair<A,B>>,NotUsed> create()

Create a new ZipLatest operator with the specified input types and zipping-function which creates org.apache.pekko.japi.Pairs.