From e11da44ac95a62ecb8fab303b843d4466cd0fc1b Mon Sep 17 00:00:00 2001
From: tursom <tursom@foxmail.com>
Date: Tue, 5 Apr 2022 18:12:49 +0800
Subject: [PATCH] add fastSlowTicker

---
 .../src/main/kotlin/cn/tursom/core/coroutine/utils.kt          | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 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
index ccff22f..53c603d 100644
--- 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
     }