Я хочу, чтобы channel.receive()
сделал тайм-аут, чтобы выполнить другие действия, когда канал не получает сообщение по истечении определенного времени.
Я пытался использовать блок withTimeout (), но на самом деле это не время ожидания.
val incomingNotification = withTimeout(1000L) {
(session.outgoing as Channel<Frame>).receive()
}
Может быть, receive()
на самом деле не подлежит отмене?
Что я делаю не так?