whereType<T> method

Stream<T> whereType<T>()

Filtered stream of data of type T.

Implementation

Stream<T> whereType<T>() =>
    transform<T>(StreamTransformer<Object, T>.fromHandlers(
      handleData: (data, sink) => switch (data) {
        T valid => sink.add(valid),
        _ => null,
      },
    )).asBroadcastStream();