diff --git a/tgbotapi.extensions.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/FlowsAggregation.kt b/tgbotapi.extensions.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/FlowsAggregation.kt index 49e717f89e..b3149217cb 100644 --- a/tgbotapi.extensions.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/FlowsAggregation.kt +++ b/tgbotapi.extensions.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/FlowsAggregation.kt @@ -2,7 +2,6 @@ package dev.inmo.tgbotapi.extensions.utils import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.channels.BroadcastChannel -import kotlinx.coroutines.channels.Channel import kotlinx.coroutines.flow.* /** @@ -11,7 +10,7 @@ import kotlinx.coroutines.flow.* fun aggregateFlows( withScope: CoroutineScope, vararg flows: Flow, - internalBufferSize: Int = Channel.BUFFERED + internalBufferSize: Int = 64 ): Flow { val sharedFlow = MutableSharedFlow(extraBufferCapacity = internalBufferSize) val bc = BroadcastChannel(internalBufferSize)