scanAsync

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

Signature

def scanAsync[T](zero: T)(f: (T, Out) => Future[T]): Repr[T]

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

Note that the zero value must be immutable.

emits when the Future CompletionStage resulting from the function scanning the element resolves to the next value

backpressures when downstream backpressures

completes when upstream completes and the last Future CompletionStage is resolved