АЕ
Надо завернуть read() в suspendCancellableCoroutine и перед ним вешать коллбек на отмену, который закроет канал
и верно, не подумал, что можно просто внутри flow засуспендить read.
Size: a a a
2020 July 28
АЕ
Ktor делает всё через engine, а там уж всякое бывает, особенно на андроиде
engine это для http client, а network лежит уровнем ниже
АЕ
то есть, я так понял что engine работает на низкоуровневых сокетах, а не наоборот
VP
engine это для http client, а network лежит уровнем ниже
Ну да, но конкретный engine может делать запросы через что угодно (или не делать их вообще, есть реализация для тестов)
VP
Через ktor-network работает только CIO
АЕ
а я и хочу ktor-network напрямую использовать, без engine)
VP
а я и хочу ktor-network напрямую использовать, без engine)
Я вас не пойму. Вы если хотите неблокирующие сокеты на старом андроиде, оно не взлетит.
AM
я пока не понимаю как его закрыть если в корутине случился блокирующий read
В относительно свежих корутинах завезли вот такую штуку для кооперации между отменяемым миром корутин и прерываемым миром потоков. Я без понятия, реагирует ли read в NIO на прерывания, но, возможно, оно вам поможет.
https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/run-interruptible.html
https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/run-interruptible.html
АЕ
Я вас не пойму. Вы если хотите неблокирующие сокеты на старом андроиде, оно не взлетит.
я пока не понимаю, почему. Я вижу в ktor-network абстракцию для suspend-сокетов. Основной класс там - SocketImpl. У него под капотом ByteBufferChannel. И нигде в реализации этого модуля я не вижу AsynchronousSocketChannel. Пока не докопался досконально, но я так понимаю, что в Ktor просто написана своя версия неблокирующих сокетов, и из NIO там используется не всё.
АЕ
Могу быть неправ на каждом шагу, разумеется, но попробовать запустить на 5 андроиде всё-таки хочу)
АЕ
В относительно свежих корутинах завезли вот такую штуку для кооперации между отменяемым миром корутин и прерываемым миром потоков. Я без понятия, реагирует ли read в NIO на прерывания, но, возможно, оно вам поможет.
https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/run-interruptible.html
https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/run-interruptible.html
ого, интересная штука, спасибо)
АЕ
Щас покопаю и отпишусь попозже, как что работает. 3 гипотезы:
1) ktor-network
2) suspendCancellableCoroutine + blocking read
3) runInterruptible
1) ktor-network
2) suspendCancellableCoroutine + blocking read
3) runInterruptible
AM
я пока не понимаю, почему. Я вижу в ktor-network абстракцию для suspend-сокетов. Основной класс там - SocketImpl. У него под капотом ByteBufferChannel. И нигде в реализации этого модуля я не вижу AsynchronousSocketChannel. Пока не докопался досконально, но я так понимаю, что в Ktor просто написана своя версия неблокирующих сокетов, и из NIO там используется не всё.
Вполне возможный вариант, так как на андроиде как-то работать надо. :)
AM
Да и не только на андроиде, всё же котлин не JDK 8+
АЕ
Да и на остальных платформах. Ktor же MPP всё-таки
AM
Да и на остальных платформах. Ktor же MPP всё-таки
Ну на остальных платформах NIO даже на полшишечки не используется, при этом они могут предоставлять свои примитивы для асинхронного I/O.
АЕ
при runInterruptible из read вылетает ClosedByInterruptException. Неплохо, радует)
AN
Котлин-спеку подвезли: https://discuss.kotlinlang.org/t/kotlin-language-specification-request-for-comments/18607
AS
Sup guys, just hopped to say hi✌🏻
I'm new to Kotlin but I won't bother you with my questions for now instead I'll go through the Docs and FAQ first :)
I'm new to Kotlin but I won't bother you with my questions for now instead I'll go through the Docs and FAQ first :)
D
Sup guys, just hopped to say hi✌🏻
I'm new to Kotlin but I won't bother you with my questions for now instead I'll go through the Docs and FAQ first :)
I'm new to Kotlin but I won't bother you with my questions for now instead I'll go through the Docs and FAQ first :)
👋🏻 Feel free to send newbie questions to @kotlin_start channel.