zipWithIndex

Zips elements of current flow with its indices.

Fan-in operators

Signature

Source.zipWithIndexSource.zipWithIndex Flow.zipWithIndexFlow.zipWithIndex

Description

Zips elements of current flow with its indices.

See also:

• zip
• zipAll
• zipWith

Example

Scala

copysourceimport org.apache.pekko
import pekko.stream.scaladsl.Source
import pekko.stream.scaladsl.Sink

    Source(List("apple", "orange", "banana")).zipWithIndex.runWith(Sink.foreach(println))
    // this will print ('apple', 0), ('orange', 1), ('banana', 2)

Java

copysourceimport org.apache.pekko.stream.javadsl.Keep;
import org.apache.pekko.stream.javadsl.Source;
import org.apache.pekko.stream.javadsl.Sink;

import java.util.*;

Source.from(Arrays.asList("apple", "orange", "banana"))
    .zipWithIndex()
    .runForeach(System.out::println, system);
// this will print ('apple', 0), ('orange', 1), ('banana', 2)

Reactive Streams semantics