on<T extends E> abstract method

StreamSubscription<T> on<T extends E>(
  1. void onData(
    1. T event
    ), {
  2. Stream<T> modify(
    1. Stream<T> stream
    )?,
  3. Function? onError,
  4. void onDone()?,
  5. bool? cancelOnError,
  6. StreamTransformer<T, T>? transform,
})

Подписаться на события типа E Пример:

  eventsSubscriptions.on<UserLoggedIn>((event) {
    print('Logged in: ${event.userId}');
  });

Возвращаем подписку, если вдруг понадобится отменить именно её вручную.

Implementation

StreamSubscription<T> on<T extends E>(
  void Function(T event) onData, {
  Stream<T> Function(Stream<T> stream)? modify,
  Function? onError,
  void Function()? onDone,
  bool? cancelOnError,
  StreamTransformer<T, T>? transform,
});