VP
А он без движка-то не поднимется
По ссылке никаких движков нету. CIO работает поверх этих сокетов, а не наоборот.
Size: a a a
2020 July 28
VP
Андроид. Альтернатив особо нет, раньше была попытка вроде в корутинах сделать интеграцию с NIO, но видимо она переехала в ктор. А самому писать пока не хочется)
Ух, вот там надо смотреть, поддерживается ли в нужной версии это всё
AN
По ссылке никаких движков нету. CIO работает поверх этих сокетов, а не наоборот.
А, кстати да. Давно не смотрел
АЕ
Ух, вот там надо смотреть, поддерживается ли в нужной версии это всё
в нужной версии чего что?
VP
в нужной версии чего что?
В нужной версии Android, на которой хочется это использовать
VP
До недавнего времени там был только огрызок NIO
АЕ
ktor-client-android зависит от
ktor-client-core, а тот от ktor-network, так что по идее ktor-network должен сам по себе работать. Разумеется, проверю)VP
ktor-client-android зависит от
ktor-client-core, а тот от ktor-network, так что по идее ktor-network должен сам по себе работать. Разумеется, проверю)Это не то чтобы что-то доказывает.
Надо смотреть, в какой версии API добавили ту часть NIO, которая про неблокирующий ввод-вывод.
Надо смотреть, в какой версии API добавили ту часть NIO, которая про неблокирующий ввод-вывод.
АЕ
ага, классно, с 26. И как жить?
VP
ага, классно, с 26. И как жить?
С minSdk 26 🌚
VP
Либо забыть про неблокирующий ввод-вывод и делать свою обёртку поверх SocketChannel
АЕ
Тогда снова возврат к тому же вопросу: как по cancel отменять заблокированный read. Тут видимо 2 варианта:
1) Никак. Тупо сделать отдельный метод close у моей абстракции, и не надеяться что при scope.cancel она остановит всю работу.
2) Изобрести какой-то сложный велосипед даже пока не очень представляю как.
1) Никак. Тупо сделать отдельный метод close у моей абстракции, и не надеяться что при scope.cancel она остановит всю работу.
2) Изобрести какой-то сложный велосипед даже пока не очень представляю как.
VP
Тогда снова возврат к тому же вопросу: как по cancel отменять заблокированный read. Тут видимо 2 варианта:
1) Никак. Тупо сделать отдельный метод close у моей абстракции, и не надеяться что при scope.cancel она остановит всю работу.
2) Изобрести какой-то сложный велосипед даже пока не очень представляю как.
1) Никак. Тупо сделать отдельный метод close у моей абстракции, и не надеяться что при scope.cancel она остановит всю работу.
2) Изобрести какой-то сложный велосипед даже пока не очень представляю как.
Вариант всего один: закрывать канал, если выполняющаяся на нём операция отменена
VP
Ну и выполнять все операции на Dispatchers.IO конечно же
АЕ
я пока не понимаю как его закрыть если в корутине случился блокирующий read
АЕ
flow {
while (isActive) {
channel.read()
}
}АЕ
условно в таком случае
АЕ
о, шок-контент: кажется, ktor не использует AsynchronousSocketChannel
VP
о, шок-контент: кажется, ktor не использует AsynchronousSocketChannel
Ktor делает всё через engine, а там уж всякое бывает, особенно на андроиде
VP
flow {
while (isActive) {
channel.read()
}
}Надо завернуть read() в suspendCancellableCoroutine и перед ним вешать коллбек на отмену, который закроет канал