Stream<Event> transformEvents( Stream<Event> events, Stream<Event> Function(Event event) mapper, ) { return events.asyncExpand(mapper); }