filterTo method

StreamSubscription filterTo(
  1. FieldControl controller, {
  2. Function? onError,
  3. void onDone()?,
  4. bool cancelOnError = false,
  5. ValueConverter? converter,
  6. Predicate<T>? filter,
})

Filters data into given controller.

Implementation

StreamSubscription filterTo(FieldControl controller,
    {Function? onError,
    void onDone()?,
    bool cancelOnError = false,
    ValueConverter? converter,
    Predicate<T>? filter}) {
  return subscribeStream(
    (data) {
      if (filter != null) {
        data = data!.where(filter).toList();
      }

      controller.setValue(converter != null ? converter(data) : data);
    },
    onError: onError,
    onDone: onDone,
    cancelOnError: cancelOnError,
  );
}