Add whereType transformer (dart-lang/stream_transform#60)
This needs to be implemented as it's own class instead of using
one of the helpers like `fromHandlers` because it has unique generic
type requirements. We want to avoid requring the call site to re-specify
the generic type of the input stream. The return type needs to be a
`StreamTransformer<Null, R>` to satisfy static checking.
However the argument to `bind` at runtime will never be a `Stream<Null>`
so we need to define it explicitly to widen the allowed argument.
6 files changed
tree: bee90df50aada5e4b68a10e79d07f50716f6f434
- pkgs/