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 b3149217cb..bf4c4b8f74 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
@@ -13,13 +13,12 @@ fun <T> aggregateFlows(
     internalBufferSize: Int = 64
 ): Flow<T> {
     val sharedFlow = MutableSharedFlow<T>(extraBufferCapacity = internalBufferSize)
-    val bc = BroadcastChannel<T>(internalBufferSize)
     flows.forEach {
         it.onEach {
             safely { sharedFlow.emit(it) }
         }.launchIn(withScope)
     }
-    return bc.asFlow()
+    return sharedFlow
 }
 
 fun <T> Flow<Iterable<T>>.flatMap(): Flow<T> = flow {