o

akka.stream.javadsl

ZipLatest

object ZipLatest

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

Source
Graph.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ZipLatest
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def create[A, B]: Graph[FanInShape2[A, B, Pair[A, B]], NotUsed]

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