Acceptance of a new event
@override Future<T?> accept([T? data]) { stateSubject.add(data); return stateSubject.stream.first; }