Merge pull request #53 from soil-kt/tweak_flow_ext

Use `produceIn` instead `toReceiveChannel` of custom operator

soil-query-core/src/commonMain/kotlin/soil/query/core/FlowExt.kt

@@ -3,19 +3,15 @@
 
 package soil.query.core
 
-import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.FlowPreview
-import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.channels.ClosedReceiveChannelException
-import kotlinx.coroutines.channels.ReceiveChannel
 import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.flow.debounce
 import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.produceIn
 import kotlinx.coroutines.isActive
-import kotlinx.coroutines.launch
 import kotlinx.coroutines.selects.select
 import kotlin.time.Duration
 
@@ -33,7 +29,7 @@ internal fun <T> Flow<T>.chunkedWithTimeout(
             val ticker = MutableSharedFlow<Unit>(extraBufferCapacity = size)
             val tickerTimeout = ticker
                 .debounce(duration)
-                .toReceiveChannel(this)
+                .produceIn(this)
             try {
                 while (isActive) {
                     var isTimeout = false
@@ -63,15 +59,3 @@ internal fun <T> Flow<T>.chunkedWithTimeout(
         }
     }
 }
-
-private fun <T> Flow<T>.toReceiveChannel(scope: CoroutineScope): ReceiveChannel<T> {
-    val channel = Channel<T>(Channel.BUFFERED)
-    scope.launch {
-        try {
-            collect { value -> channel.send(value) }
-        } finally {
-            channel.close()
-        }
-    }
-    return channel
-}