changeStream property

Stream<RType> changeStream

Implementation

Stream<RType> get changeStream {
  if (isShuttingDown()) {
    return Stream.empty();
  } else {
    return _allChangeStream.stream
        .where((r) => !r.isLoad && r.record != null)
        .map((r) => r.record!);
  }
}