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!);
}
}