jlengrand/ktor
1
0
Fork 0
mirror of https://github.com/jlengrand/ktor.git synced 2026-03-10 08:31:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

Avoid inconsistent state check

Browse Source
This commit is contained in:
Sergey Mashkov
2019-08-26 13:39:54 +03:00
parent ab91da5c78
commit e8c33fe5a3
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ktor-io/jvm/src/io/ktor/utils/io/ByteBufferChannel.kt
View File

@@ -1870,8 +1870,10 @@ internal class ByteBufferChannel(
try {
result = visitor(this)
} finally {
if (!state.idle && state !== ReadWriteBufferState.Terminated) {
if (state is ReadWriteBufferState.Reading || state is ReadWriteBufferState.ReadingWriting) {
val stateSnapshot = state
if (!stateSnapshot.idle && stateSnapshot !== ReadWriteBufferState.Terminated) {
if (stateSnapshot is ReadWriteBufferState.Reading || stateSnapshot is ReadWriteBufferState.ReadingWriting) {
restoreStateAfterRead()
}
tryTerminate()