watch<T> method

Stream<T?> watch<T>(
  1. String key
)

Implementation

Stream<T?> watch<T>(String key) {
  return Rx.merge([
    Stream.value(_dataSubject.value[key] as T?),
    _updateSubject
        .where((updatedKey) => updatedKey == key)
        .map((_) => _dataSubject.value[key] as T?),
  ]).distinct();
}