Package akka.stream.scaladsl
Class ZipLatest<A,B>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<FanInShape2<A1,A2,O>>
-
- akka.stream.scaladsl.ZipLatestWith2<A,B,scala.Tuple2<A,B>>
-
- akka.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 aleft
and aright
input port and oneout
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 akka.stream.Graph
Graph.GraphMapMatVal<S extends Shape,M>
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <A,B>
ZipLatest<A,B>apply()
Create a newZipLatest
.static <A,B>
ZipLatest<A,B>apply(boolean eagerComplete)
Create a newZipLatest
.java.lang.String
toString()
-
Methods inherited from class akka.stream.scaladsl.ZipLatestWith2
createLogic, eagerComplete, in0, in1, initialAttributes, out, shape, zipper
-
Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue
-
Methods inherited from class akka.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 akka.stream.Graph
addAttributes, async, async, async, getAttributes, named
-
-