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

Constructor Summary

Constructors

Constructor

Description

ZipLatest()
Method Summary

Modifier and Type

Method

Description

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

Constructor Details
- ZipLatest
  
  public ZipLatest()
Method Details
- create
  
  public static <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.