Fix readRemaining

e5l · cy6erGn0m · commit 64f1ada02922 · 2019-02-05T15:22:00.000+03:00
diff --git a/kotlinx-coroutines-io/common/src/kotlinx/coroutines/io/ByteChannelSequential.kt b/kotlinx-coroutines-io/common/src/kotlinx/coroutines/io/ByteChannelSequential.kt
@@ -329,7 +329,7 @@ abstract class ByteChannelSequentialBase(initial: IoBuffer, override val autoFlu
             builder.writePacket(readable)
             afterRead()
 
-            if (writable.size == 0 && closed) break
+            if (readable.remaining == 0L && writable.size == 0 && closed) break
 
             awaitSuspend(1)
         }

Original file line number	Diff line number	Diff line change
`@@ -329,7 +329,7 @@ abstract class ByteChannelSequentialBase(initial: IoBuffer, override val autoFlu`
`329`	`329`	`builder.writePacket(readable)`
`330`	`330`	`afterRead()`
`331`	`331`
`332`		`- if (writable.size == 0 && closed) break`
	`332`	`+ if (readable.remaining == 0L && writable.size == 0 && closed) break`
`333`	`333`
`334`	`334`	`awaitSuspend(1)`
`335`	`335`	`}`