В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Kotlin Community

3520 membersпожаловаться на группу
2020 July 28

VP

Vladimir Petrakovich in Kotlin Community
Алексей Ершов
У меня сейчас просто flow{} и внутри открывается канал. Как туда впихнуть suspendCancellableCoroutine?
Вы слишком разного уровня абстракции пытаетесь связать.
Сначала сделайте обёртку над SocketChannel, которая не блокирует поток и прекращает операцию при отмене вызывающей корутины, а потом уже к flow переходите.
источник
13:55пожаловаться#1

AN

Alexander Nozik in Kotlin Community
Алексей Ершов
Между - понятное дело, делаю, ensureActive. Но основное время все-таки проходит в блоке, в ожидании байтиков из сокета.
Ну так никак, оно таки блокируеще, тольк тред прерывать, что не рекомендуется.
источник
13:56пожаловаться#2

АЕ

Алексей Ершов... in Kotlin Community
Vladimir Petrakovich
Вы слишком разного уровня абстракции пытаетесь связать.
Сначала сделайте обёртку над SocketChannel, которая не блокирует поток и прекращает операцию при отмене вызывающей корутины, а потом уже к flow переходите.
Воо, отлично, это и хотел услышать) типа SuspendingSocketChannel
источник
13:56пожаловаться#3

АЕ

Алексей Ершов... in Kotlin Community
Готовых не знаете?
источник
13:56пожаловаться#4

VP

Vladimir Petrakovich in Kotlin Community
Алексей Ершов
У меня сейчас просто flow{} и внутри открывается канал. Как туда впихнуть suspendCancellableCoroutine?
Ну а впихивать надо в обертку над блокирующим read()
источник
13:57пожаловаться#5

VP

Vladimir Petrakovich in Kotlin Community
Алексей Ершов
Готовых не знаете?
В Ktor (CIO) всё должно быть. Причём такая реализация, которая вообще не блокирует треды.
источник
13:57пожаловаться#6

AN

Alexander Nozik in Kotlin Community
Vladimir Petrakovich
В Ktor (CIO) всё должно быть. Причём такая реализация, которая вообще не блокирует треды.
так там скорее всего асинхронный канал
источник
13:58пожаловаться#7

АЕ

Алексей Ершов... in Kotlin Community
Надо блокирующий read заменить на suspend read, а внутри скорее всего будет SocketChannel с non-blocking mode
источник
13:58пожаловаться#8

VP

Vladimir Petrakovich in Kotlin Community
Alexander Nozik
так там скорее всего асинхронный канал
Ну да, конечно)
источник
13:58пожаловаться#9

AN

Alexander Nozik in Kotlin Community
Vladimir Petrakovich
Ну да, конечно)
а для него проблем нет, там все ручки торчат
источник
13:58пожаловаться#10

АЕ

Алексей Ершов... in Kotlin Community
Vladimir Petrakovich
В Ktor (CIO) всё должно быть. Причём такая реализация, которая вообще не блокирует треды.
О, вот это очень интересно, пойду искать. Огромное спасибо!
источник
13:58пожаловаться#11

AN

Alexander Nozik in Kotlin Community
Алексей Ершов
Надо блокирующий read заменить на suspend read, а внутри скорее всего будет SocketChannel с non-blocking mode
Не получится
источник
13:58пожаловаться#12

АЕ

Алексей Ершов... in Kotlin Community
Alexander Nozik
Не получится
У ктора же получилось?)
источник
13:58пожаловаться#13

AN

Alexander Nozik in Kotlin Community
Вам вот эта штука нужна: https://docs.oracle.com/javase/7/docs/api/java/nio/channels/AsynchronousSocketChannel.html
источник
13:58пожаловаться#14

AN

Alexander Nozik in Kotlin Community
Алексей Ершов
У ктора же получилось?)
так я не думаю, что там блокирующий канал.
источник
13:59пожаловаться#15

АЕ

Алексей Ершов... in Kotlin Community
А, да, точно, эту штуку видел.
источник
13:59пожаловаться#16

AN

Alexander Nozik in Kotlin Community
Ну а тут прблем нет, все ручки наружу торчат.
источник
13:59пожаловаться#17

VP

Vladimir Petrakovich in Kotlin Community
Алексей Ершов
Надо блокирующий read заменить на suspend read, а внутри скорее всего будет SocketChannel с non-blocking mode
Вы с SocketChannel без блокировки вряд ли что-то сделаете, non-blocking mode - это "не получилось без блокировки - ну и ладно, не буду делать".
источник
13:59пожаловаться#18

VP

Vladimir Petrakovich in Kotlin Community
А надо взять селектор (который из NIO) и вот это вот всё
источник
14:00пожаловаться#19

АЕ

Алексей Ершов... in Kotlin Community
Справедливо, пойду async версию и ктор изучать
источник
14:00пожаловаться#20