fix: (buffersink) copy map for flow emit

silenium-dev · silenium-dev · commit e9463afcc6fa · 2024-08-10T22:38:44.000+02:00
diff --git a/src/main/kotlin/dev/silenium/libs/flows/buffer/BufferSink.kt b/src/main/kotlin/dev/silenium/libs/flows/buffer/BufferSink.kt
@@ -17,7 +17,7 @@ class BufferSink<T, P>(vararg pads: Pair<UInt, P>) : Sink<T, P> {
 
     override suspend fun receive(item: FlowItem<T, P>): Result<Unit> {
         buffer_.getOrPut(item.pad, ::mutableListOf).add(item)
-        flow_.emit(buffer)
+        flow_.emit(buffer.entries.associate { it.key to it.value.toList() })
         return Result.success(Unit)
     }
 

Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ class BufferSink<T, P>(vararg pads: Pair<UInt, P>) : Sink<T, P> {`
`17`	`17`
`18`	`18`	`override suspend fun receive(item: FlowItem<T, P>): Result<Unit> {`
`19`	`19`	`buffer_.getOrPut(item.pad, ::mutableListOf).add(item)`
`20`		`- flow_.emit(buffer)`
	`20`	`+ flow_.emit(buffer.entries.associate { it.key to it.value.toList() })`
`21`	`21`	`return Result.success(Unit)`
`22`	`22`	`}`
`23`	`23`