SunnyObservableMap<K, V>.ofStream constructor

SunnyObservableMap<K, V>.ofStream(
  1. Map<K, V> initial,
  2. Stream<Map<K, V>> stream, {
  3. String? debugLabel,
  4. DiffEquality? diffEquality,
})

Implementation

SunnyObservableMap.ofStream(Map<K, V> initial, Stream<Map<K, V>> stream, {this.debugLabel, DiffEquality? diffEquality})
    : _diffEquality = diffEquality ?? DiffEquality(),
      super.of(initial) {
  _initialize();
  syncAndListenFrom(stream, start: initial);
}