map<R> method

StreamObservable<R> map<R>(
  1. R mapper(
    1. T data
    )
)

Transforms the stream using a mapping function mapper.

Returns a new StreamObservable<R> with mapped values.

⚠️ Requires (listen) to be called first.

Implementation

StreamObservable<R> map<R>(R Function(T data) mapper) {
  if (_stream == null) {
    throw StateError('Call listen() first before using map()');
  }

  final newObs = StreamObservable<R>();
  final newStream = _stream!.map(mapper);
  newObs.listen(newStream);
  return newObs;
}