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);
}