EventTransformer<Event> typedef

EventTransformer<Event> = Stream<Event> Function(Stream<Event> events, EventMapper<Event> mapper)

Used to change how events are processed. By default events are processed concurrently.

Implementation

typedef EventTransformer<Event> = Stream<Event> Function(
  Stream<Event> events,
  EventMapper<Event> mapper,
);