on<E extends CacheEvent<T>> method

@override Stream<E> on<E extends CacheEvent<T>>()

Listens for events of Type T and its subtypes.

The method is called like this: myCache.on

If the method is called without a type parameter, the Stream contains every event of this Cache.

The returned Stream is a broadcast stream so multiple subscriptions are allowed.

Implementation

@override
Stream<E> on<E extends CacheEvent<T>>() {
  return StreamGroup.merge([_primary.on<E>(), _secondary.on<E>()]);
}