fix update of bufferEndSegment

de-shyt · de-shyt · commit bd5a4c87482d · 2024-12-17T22:07:58.000+01:00
diff --git a/kotlinx-coroutines-core/common/src/channels/BufferedChannel.kt b/kotlinx-coroutines-core/common/src/channels/BufferedChannel.kt
@@ -2422,7 +2422,7 @@ internal open class BufferedChannel<E>(
                 val segment = it.segment
                 // Advance the `bufferEnd` segment if required.
                 if (!isRendezvousOrUnlimited && id <= bufferEndCounter / SEGMENT_SIZE) {
-                    bufferEndSegment.moveForward(segment)
+                    bufferEndSegment.value.let { bufferEndSegment.moveToSpecifiedOrLast(id, it) }
                 }
                 // Is the required segment removed?
                 if (segment.id > id) {

Original file line number	Diff line number	Diff line change
`@@ -2422,7 +2422,7 @@ internal open class BufferedChannel<E>(`
`2422`	`2422`	`val segment = it.segment`
`2423`	`2423`	// Advance the `bufferEnd` segment if required.
`2424`	`2424`	`if (!isRendezvousOrUnlimited && id <= bufferEndCounter / SEGMENT_SIZE) {`
`2425`		`- bufferEndSegment.moveForward(segment)`
	`2425`	`+ bufferEndSegment.value.let { bufferEndSegment.moveToSpecifiedOrLast(id, it) }`
`2426`	`2426`	`}`
`2427`	`2427`	`// Is the required segment removed?`
`2428`	`2428`	`if (segment.id > id) {`