From 4d853f0338158520e7b8da582581afce7fdb43b5 Mon Sep 17 00:00:00 2001
From: Adam Brown <adampsbrown@gmail.com>
Date: Fri, 4 Nov 2022 11:16:10 +0000
Subject: [PATCH] porting to flow concat for the initial sync state read

---
 .../app/dapk/st/matrix/sync/internal/DefaultSyncService.kt      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/internal/DefaultSyncService.kt b/matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/internal/DefaultSyncService.kt
index 3eb9136..13a9076 100644
--- a/matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/internal/DefaultSyncService.kt
+++ b/matrix/services/sync/src/main/kotlin/app/dapk/st/matrix/sync/internal/DefaultSyncService.kt
@@ -107,7 +107,7 @@ internal class DefaultSyncService(
     }
 
     override fun startSyncing(): Flow<Unit> {
-        return flow { emit(syncStore.read(SyncStore.SyncKey.Overview) != null) }.flatMapMerge { hasSynced ->
+        return flow { emit(syncStore.read(SyncStore.SyncKey.Overview) != null) }.flatMapConcat { hasSynced ->
             when (hasSynced) {
                 true -> syncFlow.filter { false }.onStart { emit(Unit) }
                 false -> {