action on each element of this stream.
Completes the returned
Future when all elements of this stream
have been processed.
If this stream emits an error, or if the call to
the returned future completes with that error,
and processing stops.
@override AsObservableFuture<dynamic> forEach(void action(T element)) => AsObservableFuture<dynamic>(_stream.forEach(action));