zipAll

Combines elements from two sources into tuples Pair handling early completion of either source.

Fan-in operators

Signature

Source.zipAllSource.zipAll Flow.zipAllFlow.zipAll

Description

Combines elements from two sources into tuples Pair and passes downstream. If either source completes, a default value is combined with each value from the other source until it completes.

See also:

• zip
• zipWith
• zipWith
• zipWithIndex

Example

Scala

copysourceval numbers = Source(1 :: 2 :: 3 :: 4 :: Nil)
val letters = Source("a" :: "b" :: "c" :: Nil)

numbers.zipAll(letters, -1, "default").runForeach(println)
// prints:
// (1,a)
// (2,b)
// (3,c)
// (4,default)

Java

copysource
Source<Integer, NotUsed> numbers = Source.from(Arrays.asList(1, 2, 3, 4));
Source<String, NotUsed> letters = Source.from(Arrays.asList("a", "b", "c"));

numbers.zipAll(letters, -1, "default").runForeach(System.out::println, system);
// prints:
// Pair(1,a)
// Pair(2,b)
// Pair(3,c)
// Pair(4,default)

Reactive Streams semantics