Kotlin channel.receive () не блокируется при использовании в блоке withTimeout () - PullRequest
0 голосов
/ 14 марта 2019

Я хочу, чтобы channel.receive() сделал тайм-аут, чтобы выполнить другие действия, когда канал не получает сообщение по истечении определенного времени.

Я пытался использовать блок withTimeout (), но на самом деле это не время ожидания.

val incomingNotification = withTimeout(1000L) {
    (session.outgoing as Channel<Frame>).receive()
}

Может быть, receive() на самом деле не подлежит отмене? Что я делаю не так?

...