init method

void init()

Implementation

void init() {
  final normalStream = _subject.stream.where((event) => !event.needsThrottle);

  final movingStream =
      _subject.stream.where((event) => event.needsThrottle).transform(
            ThrottleStreamTransformer(
              (_) => TimerStream(_, const Duration(milliseconds: 1)),
            ),
          );

  _subscription = MergeStream([normalStream, movingStream]).listen(_handler);
}