addToStream method

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

Implementation

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