@override Future addStream(Stream<T> source, {bool? cancelOnError}) => eventStream!.addStream(source, cancelOnError: cancelOnError);