Add SharingStarted helper

sipgate · May 22, 2024 · ce17c06 · ce17c06
1 parent 2227f61
commit ce17c06
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/dachlatten-flow/src/main/kotlin/de/sipgate/dachlatten/flow/SharingStartedExt.kt b/dachlatten-flow/src/main/kotlin/de/sipgate/dachlatten/flow/SharingStartedExt.kt
@@ -0,0 +1,8 @@
+package de.sipgate.dachlatten.flow
+
+import kotlinx.coroutines.flow.SharingStarted
+import kotlin.time.Duration
+
+fun SharingStarted.WhileSubscribed(duration: Duration): SharingStarted {
+    return SharingStarted.WhileSubscribed(stopTimeoutMillis = duration.inWholeMilliseconds)
+}