bind method

  1. @override
Stream<T> bind(
  1. Stream<T> stream
)
override

Stream values are throttled by checking the response from Throttle.duration, using _noop as the target method. If Throttle.duration returns true, emit the stream value.

Implementation

@override
Stream<T> bind(Stream<T> stream) async* {
  await for (final value in stream) {
    final _yield = Throttle.duration(duration, _noop);
    if (_yield) yield value;
  }
}