ValueStream<T>.shrine constructor

ValueStream<T>.shrine(
  1. Iterable<Stream> streams,
  2. T getter(), {
  3. bool distinctValues = true,
})

Implementation

factory ValueStream.shrine(
  Iterable<Stream> streams,
  T Function() getter, {
  bool distinctValues = true,
}) {
  return ValueStream(
    const Stream.empty().mergeAll(streams).map((e) => getter()),
    getter,
    distinctValues: distinctValues,
  );
}