- S initialValue,
- S combine(
- S previous,
- T element
Combines a sequence of values by repeatedly applying
Similar to Iterable.fold, this function maintains a value,
initialValue and updated for each element of
For each element, the value is updated to the result of calling
combine with the previous value and the element.
When this stream is done, the returned future is completed with
the value at that time.
For an empty stream, the future is completed with
If this stream emits an error, or the call to
the returned future is completed with that error,
and processing is stopped.
@override AsObservableFuture<S> fold<S>( S initialValue, S combine(S previous, T element)) => AsObservableFuture<S>(_stream.fold(initialValue, combine));