summaryrefslogtreecommitdiff
path: root/sw-ui/src
diff options
context:
space:
mode:
authorJoffrey Bion <joffrey.bion@gmail.com>2021-09-08 09:13:15 +0200
committerJoffrey Bion <joffrey.bion@gmail.com>2021-09-08 09:13:15 +0200
commit6acf7c91a6f30f6b16bb54f4b2c173383c521149 (patch)
treead96410fcea54877fa5d7b19a43b8a378ea72f88 /sw-ui/src
parentRemove usages of deprecated route extensions (diff)
downloadseven-wonders-6acf7c91a6f30f6b16bb54f4b2c173383c521149.tar.gz
seven-wonders-6acf7c91a6f30f6b16bb54f4b2c173383c521149.tar.bz2
seven-wonders-6acf7c91a6f30f6b16bb54f4b2c173383c521149.zip
OptIn GlobalScope usage in SagasFramework
Diffstat (limited to 'sw-ui/src')
-rw-r--r--sw-ui/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt4
1 files changed, 3 insertions, 1 deletions
diff --git a/sw-ui/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt b/sw-ui/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt
index ea3fc26e..22377512 100644
--- a/sw-ui/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt
+++ b/sw-ui/src/main/kotlin/org/luxons/sevenwonders/ui/redux/sagas/SagasFramework.kt
@@ -2,6 +2,7 @@ package org.luxons.sevenwonders.ui.redux.sagas
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.BroadcastChannel
+import kotlinx.coroutines.channels.Channel.Factory.BUFFERED
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.collect
import redux.Middleware
@@ -14,7 +15,7 @@ class SagaManager<S, A : RAction, R>(
) {
private lateinit var context: SagaContext<S, A, R>
- private val actions = BroadcastChannel<A>(16)
+ private val actions = BroadcastChannel<A>(BUFFERED)
fun createMiddleware(): Middleware<S, A, R, A, R> = ::sagasMiddleware
@@ -34,6 +35,7 @@ class SagaManager<S, A : RAction, R>(
monitor?.invoke(action)
}
+ @OptIn(DelicateCoroutinesApi::class) // Ok because almost never suspends - if it does, we have bigger problems
private fun handleAction(action: A) {
GlobalScope.launch { actions.send(action) }
}
bgstack15