@override Stream<BaseEvent> get changes => Rx.merge([ eventSubject.stream, Rx.merge(observables.map((e) => e.changes)) .transform(_fieldToFormEventTransformer) ]).asBroadcastStream();