markComplete method

void markComplete(
  1. String streamName
)

Marks a stream as having completed one processing step.

Implementation

void markComplete(String streamName) {
  final stream = _streams[streamName];
  if (stream == null) return;
  stream.markSynced();
}