Keep latest state. DO NOT USE THIS METHOD
@internal @override StreamEvent<T> get event => _subject.event;