We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e4d3ce7 commit 8e13241Copy full SHA for 8e13241
core/kotlinx-coroutines-io/src/main/kotlin/kotlinx/coroutines/experimental/io/ByteBufferChannel.kt
@@ -69,7 +69,7 @@ internal class ByteBufferChannel(
69
if (closed != null) return false
70
val newClosed = if (cause == null) ClosedElement.EmptyCause else ClosedElement(cause)
71
if (!Closed.compareAndSet(this, null, newClosed)) return false
72
- flush()
+ state.capacity.flush()
73
if (state.capacity.isEmpty() || cause != null) tryTerminate()
74
resumeClosed(cause)
75
return true
0 commit comments