zipWithIndex

Zips elements of current flow with its indices.

Fan-in stages

Signature

def zipWithIndex: Repr[(Out, Long)]

Description

Zips elements of current flow with its indices.

emits upstream emits an element and is paired with their index

backpressures when downstream backpressures

completes when upstream completes

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.