onEvent<T extends TokenEvent> method

Stream<T> onEvent<T extends TokenEvent>()

Returns a typed stream of TokenEvents filtered to events of type T.

Cleaner at call sites than manually calling .whereType<T>():

keeper.onEvent<TokenRefreshedEvent>().listen((e) {
  print('new token: ${e.token.maskedAccessToken}');
});

Implementation

Stream<T> onEvent<T extends TokenEvent>() =>
    events.where((e) => e is T).cast<T>();