CancellableStreamIterator<T> constructor

CancellableStreamIterator<T>(
  1. Stream<T> stream,
  2. CancellationToken token
)

Implementation

CancellableStreamIterator(Stream<T> stream, CancellationToken token)
    : _iterator = StreamIterator(stream),
      _token = token {
  _handler = token.addHandler(() {
    unawaited(_iterator.cancel());
  });
}