addToStream method

void addToStream(
  1. RType? record, {
  2. bool isLoad = false,
  3. bool silent = false,
})

Implementation

void addToStream(RType? record, {bool isLoad = false, bool silent = false}) {
  exec(() {
    if (record != null) {
      final id = getIdForRecord(record);
      final _recordStream = _getOrCreateStream(id);
      if (silent) {
        _recordStream.updateQuiet(record);
      } else {
        _recordStream.currentValue = record;
        _allChangeStream.add(StreamChange(isLoad, record));
      }
    }
  });
}