syncFromMapList method

Future<SunnyObservableMap<K?, SunnyObservableList<L>>> syncFromMapList(
  1. ValueStream<Map<K, List<L>>> replacement
)

Implementation

Future<SunnyObservableMap<K?, SunnyObservableList<L>>> syncFromMapList(ValueStream<Map<K, List<L>>> replacement) async {
  final first = replacement.get();
  if (first is! Future) {
    await takeFromMapList(first as Map<K, Iterable<L>>);
    this.subscribedTo = replacement.after.listen(takeFromMapList, cancelOnError: false);
  } else {
    final _first = await (first as FutureOr<Map<K, List<L>>>);
    await takeFromMapList(_first);
    this.subscribedTo = replacement.after.listen(takeFromMapList, cancelOnError: false);
  }

  return this;
}