IO: make byte channel detect closed state earlier

Sergey Mashkov · Sergey Mashkov · commit 18b28a204885 · 2017-11-20T17:30:58.000+03:00
diff --git a/core/kotlinx-coroutines-io/src/main/kotlin/kotlinx/coroutines/experimental/io/ByteBufferChannel.kt b/core/kotlinx-coroutines-io/src/main/kotlin/kotlinx/coroutines/experimental/io/ByteBufferChannel.kt
@@ -142,6 +142,13 @@ internal class ByteBufferChannel(
             }
         }
 
+        if (closed != null) {
+            restoreStateAfterWrite()
+            tryTerminate()
+
+            throw closed!!.sendException
+        }
+
         val buffer = newState.writeBuffer
 
         _allocated?.let { allocated ->

Original file line number	Diff line number	Diff line change
`@@ -142,6 +142,13 @@ internal class ByteBufferChannel(`
`142`	`142`	`}`
`143`	`143`	`}`
`144`	`144`
	`145`	`+ if (closed != null) {`
	`146`	`+ restoreStateAfterWrite()`
	`147`	`+ tryTerminate()`
	`148`	`+`
	`149`	`+ throw closed!!.sendException`
	`150`	`+ }`
	`151`	`+`
`145`	`152`	`val buffer = newState.writeBuffer`
`146`	`153`
`147`	`154`	`_allocated?.let { allocated ->`