where method

StreamObservable<T> where(
  1. bool predicate(
    1. T data
    )
)

Filters the stream using a predicate function.

Returns a new StreamObservable<T> with filtered values.

⚠️ Requires listen to be called first.

Implementation

StreamObservable<T> where(bool Function(T data) predicate) {
  if (_stream == null) {
    throw StateError('Call listen() first before using where()');
  }

  final newObs = StreamObservable<T>();
  final filtered = _stream!.where(predicate);
  newObs.listen(filtered);
  return newObs;
}