changes property

@override Stream<ListChangedEvent<TElement>> changes

Implementation

@override
Stream<ListChangedEvent<TElement>> get changes => Rx.merge([
      _subject.stream,
      Rx.merge(
        innerList.whereType<IObservable<TElement>>().map((e) {
          return e.changes.transform(
            StreamTransformer.fromHandlers(
              handleData: (data, sink) => sink.add(ListChangedEvent(
                  change: ListChangeTypes.update, elements: [data])),
            ),
          );
        }),
      )
    ]);