We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fc65039 commit fe88057Copy full SHA for fe88057
packages/powersync_core/lib/src/streaming_sync.dart
@@ -331,8 +331,11 @@ class StreamingSyncImplementation implements StreamingSync {
331
: (downloadError ?? lastStatus.downloadError),
332
statusInPriority: statusInPriority ?? lastStatus.statusInPriority,
333
);
334
- lastStatus = newStatus;
335
- _statusStreamController.add(newStatus);
+
+ if (!_statusStreamController.isClosed) {
336
+ lastStatus = newStatus;
337
+ _statusStreamController.add(newStatus);
338
+ }
339
}
340
341
Future<(List<BucketRequest>, Map<String, BucketDescription?>)>
0 commit comments