foldAsync

Just like fold but receives a function that results in a Future CompletionStage to the next value.

Simple operators

Signature

def foldAsync[T](zero: T)(f: (T, Out) ⇒ Future[T]): Repr[T]

Description

Just like fold but receives a function that results in a Future CompletionStage to the next value.

Note that the zero value must be immutable.

emits when upstream completes and the last Future CompletionStage is resolved

backpressures when downstream backpressures

completes when upstream completes and the last Future CompletionStage is resolved

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.