Finish migration to kotlinx-io
This commit is contained in:
parent
fb03fcc982
commit
606c2cf5b1
@ -52,7 +52,7 @@ public class ChannelPort(
|
||||
if (num < 0) cancel("The input channel is exhausted")
|
||||
} catch (ex: Exception) {
|
||||
if(ex is AsynchronousCloseException){
|
||||
logger.info { "Channel closed" }
|
||||
logger.info { "Channel $channel closed" }
|
||||
} else {
|
||||
logger.error(ex) { "Channel read error, retrying in 1 second" }
|
||||
delay(1000)
|
||||
|
Loading…
Reference in New Issue
Block a user