fromStream<T> static method
OffsetIterator<T>
fromStream<T>(
- Stream<
T> stream, { - int retention = 0,
- SeedCallback<
T> ? seed, - String name = 'OffsetIterator.fromStream',
- 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,
);
}