T
- The element type.public interface AsyncStream<T>
Modifier and Type | Method and Description |
---|---|
CancellationToken |
forEach(AsyncStreamHandler<T> handler)
Enumerate the
AsyncStream by signaling each element to the handler.onNext . |
CancellationToken forEach(AsyncStreamHandler<T> handler)
AsyncStream
by signaling each element to the handler.onNext
.
All the elements will be enumerated as long as there is no cancellation requested and
there is no error while retrieving the element (e.g. auth error, network error).handler
- The handler to receive result of enumeration.