VP
Кто-нибудь знает почему я получаю экзепшн при закрытии веб сокета? Это весь его код на сервере, взят из примера с доков
Потому что receive() кидает исключение, если канал уже закрыт 🤷♂️
Size: a a a
2020 February 25
К
Понятно зачем там try/finally
AT
в общем, можно сказать, что оно работает, хотя решение спорное, конечно
VP
Ну если завершение вебсокетной сессии с исключением, свидетельствующем о кривом коде - это "работает", то да)
AT
я и говорю — спорное весьма
AT
но можно подавить исключение, никто и не узнает ничего 😊
U
Господа, есть нужда дождаться отмены корутины. Решение "в лоб" -
И мне кажется, что должен быть механизм получше.
try {
while(isActive) {
delay(1000)
}
} finally {
callback(...)
}И мне кажется, что должен быть механизм получше.
AT
job.join()?
U
Это когда ты снаружи
U
а мне надо изнутри suspend-функции
U
что-то вроде
awaitClose {} у FlowU
(кажется, только у callbackFlow)
VB
Господа, есть нужда дождаться отмены корутины. Решение "в лоб" -
И мне кажется, что должен быть механизм получше.
try {
while(isActive) {
delay(1000)
}
} finally {
callback(...)
}И мне кажется, что должен быть механизм получше.
можно написать свой оператор через suspendCancellableCoroutine через коллбек, наверное?
VP
а мне надо изнутри suspend-функции
Так надо навесить коллбек на отмену или что?
VP
try-finally так-то замечательный механизм
AM
Там doOnCompletion у джобы есть, ЕМНИП, можно его с CompletableDeferred использовать по идее.
D
invokeOnCompletion
AM
Точно.
U
Мне надо заюзать синхронную либу со всякими колбеками и своим состоянием внутри корутины, но "в конце" обязательно надо подчистить ресурсы.
VB
Мне надо заюзать синхронную либу со всякими колбеками и своим состоянием внутри корутины, но "в конце" обязательно надо подчистить ресурсы.
тогда вам 100% нужен suspendCancellableCoroutine