Mapper<T, R> constructor

Mapper<T, R>({
  1. required BaseIO<T> upstream,
  2. required String semantics,
  3. required R mapper(
    1. T
    ),
  4. R? seedValue,
})

Implementation

Mapper({
  required BaseIO<T> upstream,
  required super.semantics,
  required R Function(T) mapper,
  R? seedValue,
})  : _upstream = upstream,
      _mapper = mapper,
      super(
        seedValue: seedValue ?? mapper(upstream._seedValue),
      ) {
  _subscription = upstream._subject.map(mapper).listen(_subject.add);
}