Put the yield back

rossdanderson · rossdanderson · commit 55d5d8e96cdc · 2026-03-18T16:42:05.000Z
diff --git a/util/src/main/kotlin/com/caplin/integration/datasourcex/util/flow/Buffer.kt b/util/src/main/kotlin/com/caplin/integration/datasourcex/util/flow/Buffer.kt
@@ -11,6 +11,7 @@ import kotlinx.coroutines.flow.channelFlow
 import kotlinx.coroutines.flow.produceIn
 import kotlinx.coroutines.selects.onTimeout
 import kotlinx.coroutines.selects.whileSelect
+import kotlinx.coroutines.yield
 
 /**
  * Buffers all elements emitted until there is a period of no emissions greater than
@@ -35,6 +36,7 @@ fun <T> Flow<T>.bufferingDebounce(timeoutMillis: Long): Flow<List<T>> = channelF
             if (bufferedItems.isNotEmpty()) {
               send(bufferedItems)
               bufferedItems = mutableListOf()
+              yield()
             }
             it?.let { throw it }
           }

Original file line number	Diff line number	Diff line change
`@@ -11,6 +11,7 @@ import kotlinx.coroutines.flow.channelFlow`
`11`	`11`	`import kotlinx.coroutines.flow.produceIn`
`12`	`12`	`import kotlinx.coroutines.selects.onTimeout`
`13`	`13`	`import kotlinx.coroutines.selects.whileSelect`
	`14`	`+import kotlinx.coroutines.yield`
`14`	`15`
`15`	`16`	`/**`
`16`	`17`	`* Buffers all elements emitted until there is a period of no emissions greater than`
`@@ -35,6 +36,7 @@ fun <T> Flow<T>.bufferingDebounce(timeoutMillis: Long): Flow<List<T>> = channelF`
`35`	`36`	`if (bufferedItems.isNotEmpty()) {`
`36`	`37`	`send(bufferedItems)`
`37`	`38`	`bufferedItems = mutableListOf()`
	`39`	`+ yield()`
`38`	`40`	`}`
`39`	`41`	`it?.let { throw it }`
`40`	`42`	`}`