summaryrefslogtreecommitdiff
path: root/sw-ui-kt/src/main/kotlin/org/luxons
diff options
context:
space:
mode:
Diffstat (limited to 'sw-ui-kt/src/main/kotlin/org/luxons')
-rw-r--r--sw-ui-kt/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt5
1 files changed, 3 insertions, 2 deletions
diff --git a/sw-ui-kt/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt b/sw-ui-kt/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt
index c7184cea..fddaf85c 100644
--- a/sw-ui-kt/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt
+++ b/sw-ui-kt/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt
@@ -76,7 +76,7 @@ class SagaContext<S, A : RAction, R>(
}
/**
- * Starts a concurrent coroutine that executes [handle] on every action dispatched.
+ * Executes [handle] on every action dispatched. This runs forever until the current coroutine is cancelled.
*/
suspend fun onEach(handle: suspend SagaContext<S, A, R>.(A) -> Unit) {
val channel = actions.openSubscription()
@@ -90,7 +90,8 @@ class SagaContext<S, A : RAction, R>(
}
/**
- * Starts a concurrent coroutine that executes [handle] on every action dispatched of the type [T].
+ * Executes [handle] on every action dispatched of the type [T]. This runs forever until the current coroutine is
+ * cancelled.
*/
suspend inline fun <reified T : A> onEach(
crossinline handle: suspend SagaContext<S, A, R>.(T) -> Unit
bgstack15