changes property

@override Stream<BaseEvent> get changes

Implementation

@override
Stream<BaseEvent> get changes {
  if (lastEvent.status == ViewStatus.loading) {
    return eventSubject.stream.asBroadcastStream();
  }

  return Rx.merge([
    eventSubject.stream,
    Rx.merge(observables.map((e) => e.changes))
        .transform(_formToViewEventTransformer)
  ]).doOnData((event) => hasChanges = true).asBroadcastStream();
}