Mapper<T, R> constructor
Mapper<T, R> ({})
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);
}