transformEvents method

Stream<Event> transformEvents(
  1. Stream<Event> events,
  2. Stream<Event> mapper(
    1. Event event
    )
)

Implementation

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