fromStream<T> static method

OffsetIterator<T> fromStream<T>(
  1. Stream<T> stream, {
  2. int retention = 0,
  3. SeedCallback<T>? seed,
  4. String name = 'OffsetIterator.fromStream',
  5. bool cancelOnError = true,
})

Create an OffsetIterator from the provided Stream. If a ValueStream with a seed is given, it will populate the iterator's seed value.

Implementation

static OffsetIterator<T> fromStream<T>(
  Stream<T> stream, {
  int retention = 0,
  SeedCallback<T>? seed,
  String name = 'OffsetIterator.fromStream',
  bool cancelOnError = true,
}) {
  final eitherSeed = seed != null ? () => seed().p(O.map(E.right)) : null;

  return fromStreamEither<T>(
    stream,
    seed: eitherSeed,
    name: name,
  ).map(
    E.fold((l) => throw l, identity),
    retention: retention,
    cancelOnError: cancelOnError,
  );
}