We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 28cc51f commit 16e4487Copy full SHA for 16e4487
crates/core/src/sync/streaming_sync.rs
@@ -563,6 +563,8 @@ impl StreamingSyncIteration {
563
continue;
564
}
565
SyncEvent::StreamEnded => {
566
+ self.status
567
+ .update(|s| s.disconnect(), &mut event.instructions);
568
break false;
569
570
SyncEvent::DidRefreshToken => {
dart/test/sync_test.dart
@@ -207,6 +207,11 @@ void _syncTests<T>({
207
containsPair('status', containsPair('connected', true)))
208
]);
209
expect(invokeControl('connection', 'end'), [
210
+ {
211
+ 'UpdateSyncStatus': {
212
+ 'status': containsPair('connected', false),
213
+ }
214
+ },
215
{
216
'CloseSyncStream': {'hide_disconnect': false}
217
0 commit comments