а зачем она саспенд в этой реализации?
suspend fun readFully
Суспенд действительно не нужен
мне не дают вызвать readFully без него :)
а, сорри, это специфика ктор-ио. Тогда да
я посмотрел, это расширение из котлинх.корутинз-ио
Стоп, это какая-то ерунда
Как это может быть, если ByteReadChannel - кторовский тип
Должно быть что-то вроде fun ByteReadChannel.arrays() = sequence{ while(isOpen){ val array = ByteArray(256) readFully(array) emit(array) } } @y9san9
вроде как из генератора не любой саспенд раньше можно было вызвать
там надо завернуть в launch, да
может флоу лучше?
Можно кстати. Это я туплю
вот такое зафейлится, если загрузилось 10 байтов например, а у меня 256 надо.
Засуспедидтся пока все не наберется. Просто я понял, что там блоки по 256 байт. Если нет, то там есть метод readAvailable
и readAvailable тоже с ошибкой падает
Обсуждают сегодня