droppable<Event> function

EventTransformer<Event> droppable<Event>()

Process only one event and ignore (drop) any new events until the current event is done.

Note: dropped events never trigger the event handler.

Implementation

EventTransformer<Event> droppable<Event>() {
  return (events, mapper) {
    return events.transform(_ExhaustMapStreamTransformer(mapper));
  };
}