T- The element type.
public interface AsyncStream<T>
|Modifier and Type||Method and Description|
CancellationToken forEach(AsyncStreamHandler<T> handler)
AsyncStreamby 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.