Не подтверждена Коммит 55106bcd создал по автору Bruce Hamilton's avatar Bruce Hamilton Зафиксировано автором GitHub
Просмотр файлов

KTOR-8051 Revert EOFException change (#4627)

владелец 1c4f5b9a
Скрыть пробелы
Построчно Рядом
ktor-io/common/src/io/ktor/utils/io/ByteReadChannelOperations.kt
Просмотр файла @ 55106bcd
...@@ -460,9 +460,11 @@ public val ByteReadChannel.availableForRead: Int ...@@ -460,9 +460,11 @@ public val ByteReadChannel.availableForRead: Int
*/ */
@OptIn(InternalAPI::class) @OptIn(InternalAPI::class)
public suspend fun ByteReadChannel.readFully(out: ByteArray, start: Int = 0, end: Int = out.size) { public suspend fun ByteReadChannel.readFully(out: ByteArray, start: Int = 0, end: Int = out.size) {
if (end > start && isClosedForRead) throw EOFException("Channel is already closed")
var offset = start var offset = start
while (offset < end) { while (offset < end) {
if (readBuffer.exhausted()) awaitContent() if (readBuffer.exhausted()) awaitContent()
if (isClosedForRead) throw EOFException("Channel is already closed")
val count = min(end - offset, readBuffer.remaining.toInt()) val count = min(end - offset, readBuffer.remaining.toInt())
readBuffer.readTo(out, offset, offset + count) readBuffer.readTo(out, offset, offset + count)
......
Поддерживает Markdown
0% или .
You are about to add 0 people to the discussion. Proceed with caution.
Сначала завершите редактирование этого сообщения!
Пожалуйста, зарегистрируйтесь или чтобы прокомментировать