AM
В смысле?
Ну там разница в IllegalArgumentException / IllegalStateException, очевидно, выше проверялся стейт, а не входной параметр функции.
check, конечно, я их постоянно путаю.Size: a a a
2020 July 27
AS
Вечно путаю... =(
BP
Давно варнит?
Очень давно
BP
check, конечно, я их постоянно путаю.А я про чек и не знал, ну или забыл про него
PE
А я про чек и не знал, ну или забыл про него
+1
2020 July 28
АЕ
Кто делал Flow-обёртку над SocketChannel? Как внятно поддержать cancellation, чтобы когда происходит cancel, закрывать channel?
A
Кто делал Flow-обёртку над SocketChannel? Как внятно поддержать cancellation, чтобы когда происходит cancel, закрывать channel?
Конкретно над SocketChannel не делал оберток, но для других использовал onCompletion
A
Кто делал Flow-обёртку над SocketChannel? Как внятно поддержать cancellation, чтобы когда происходит cancel, закрывать channel?
Или try..catch(CancellationException), или awaitClose. Тут нужно смотреть на саму обертку.
sd
.catch или try catch
AN
Кто делал Flow-обёртку над SocketChannel? Как внятно поддержать cancellation, чтобы когда происходит cancel, закрывать channel?
Там в примере для callbackFlow есть - awaitClosed или что-то в этом роде
АЕ
Я немного не об этом говорю) по умолчанию канал блокирует поток при вызове метода чтения. Если поток заблокирован, то scope.cancel ничего с ним не сделает, а я хочу отменить текущее чтение. Получается, нужно использовать non-blocking режим чтения, и оборачивать его в cancellableCoroutine?
AN
Я немного не об этом говорю) по умолчанию канал блокирует поток при вызове метода чтения. Если поток заблокирован, то scope.cancel ничего с ним не сделает, а я хочу отменить текущее чтение. Получается, нужно использовать non-blocking режим чтения, и оборачивать его в cancellableCoroutine?
Если все заблокировано и нет ручки на отмену (а она там все-таки есть), то ничего отменить нельзя.
VP
Я немного не об этом говорю) по умолчанию канал блокирует поток при вызове метода чтения. Если поток заблокирован, то scope.cancel ничего с ним не сделает, а я хочу отменить текущее чтение. Получается, нужно использовать non-blocking режим чтения, и оборачивать его в cancellableCoroutine?
Можно закрывать канал при отмене (а отмену ловить через suspendCancellableCoroutine).
Тогда чтение должно тут же закончиться с
Тогда чтение должно тут же закончиться с
AsynchronousCloseException.AN
Можно закрывать канал при отмене (а отмену ловить через suspendCancellableCoroutine).
Тогда чтение должно тут же закончиться с
Тогда чтение должно тут же закончиться с
AsynchronousCloseException.+
АЕ
Если все заблокировано и нет ручки на отмену (а она там все-таки есть), то ничего отменить нельзя.
В асинхронном варианте есть, а в обычном read вроде нет.
AN
В асинхронном варианте есть, а в обычном read вроде нет.
Ну так пока буффер вычитывается, прервать это нельзя
АЕ
Можно закрывать канал при отмене (а отмену ловить через suspendCancellableCoroutine).
Тогда чтение должно тут же закончиться с
Тогда чтение должно тут же закончиться с
AsynchronousCloseException.У меня сейчас просто flow{} и внутри открывается канал. Как туда впихнуть suspendCancellableCoroutine?
АЕ
Ну так пока буффер вычитывается, прервать это нельзя
А он ждёт пока что-то из сокета придет, и как раз хочется это ожидание прервать)
AN
У меня сейчас просто flow{} и внутри открывается канал. Как туда впихнуть suspendCancellableCoroutine?
Вы можете проверку завершения корутины между вычиткой буферов сделать
АЕ
Между - понятное дело, делаю, ensureActive. Но основное время все-таки проходит в блоке, в ожидании байтиков из сокета.