Skip to content

Commit 50d11e3

Browse files
committed
Iterate through stream instead of listening to it
1 parent c42f586 commit 50d11e3

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

packages/powersync/lib/src/powersync_database.dart

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -197,14 +197,11 @@ class PowerSyncDatabase with SqliteQueries implements SqliteConnection {
197197
if (currentStatus.hasSynced ?? false) {
198198
return;
199199
}
200-
final completer = Completer<void>();
201-
statusStream.listen((result) {
202-
if ((result.hasSynced ?? false) && !completer.isCompleted) {
203-
completer.complete();
200+
await for (final result in statusStream) {
201+
if (result.hasSynced ?? false) {
202+
break;
204203
}
205-
});
206-
207-
return completer.future;
204+
}
208205
}
209206

210207
@override

0 commit comments

Comments
 (0)