Repeat flowing all watches

boswelja · Jun 18, 2021 · 46473b2 · 46473b2
1 parent ef122b4
commit 46473b2
Showing 1 changed file with 11 additions and 9 deletions.
diff --git a/wearos/src/main/kotlin/com/boswelja/watchconnection/wearos/WearOSDiscoveryPlatform.kt b/wearos/src/main/kotlin/com/boswelja/watchconnection/wearos/WearOSDiscoveryPlatform.kt
@@ -40,15 +40,17 @@ class WearOSDiscoveryPlatform(
     override val platformIdentifier: String = WEAROS_PLATFORM
 
     override fun allWatches(): Flow<List<Watch>> = flow {
-        emit(
-            nodeClient.connectedNodes.await().map { node ->
-                Watch(
-                    node.displayName,
-                    node.id,
-                    platformIdentifier
-                )
-            }
-        )
+        repeating(interval = scanRepeatInterval) {
+            emit(
+                nodeClient.connectedNodes.await().map { node ->
+                    Watch(
+                        node.displayName,
+                        node.id,
+                        platformIdentifier
+                    )
+                }
+            )
+        }
     }
 
     @ExperimentalCoroutinesApi