add fastSlowTicker

2026-08-19 09:33:28 +08:00 · 2022-04-05 18:12:49 +08:00
parent b94956cabc
commit e11da44ac9
1 changed files with 2 additions and 1 deletions
--- a/ts-core/ts-coroutine/src/main/kotlin/cn/tursom/core/coroutine/utils.kt
+++ b/ts-core/ts-coroutine/src/main/kotlin/cn/tursom/core/coroutine/utils.kt
@@ -265,6 +265,7 @@ fun bufferTicker(
 fun fastSlowTicker(
  fastTicker: ReceiveChannel<Unit>,
  slowTicker: ReceiveChannel<Unit>,
+  maxFailure: Int = 5,
 ) = GlobalScope.produce {
  var failure = 0
  while (true) {
@@ -276,7 +277,7 @@ fun fastSlowTicker(
    }

    failure++
-    if (failure < 5) {
+    if (failure < maxFailure) {
      send(fastTicker.receive())
      continue
    }