Reorder messages
This commit is contained in:
parent
2b698be166
commit
885bccb2d2
@ -121,8 +121,8 @@ abstract class Connection(val side: ConnectionSide, val type: ConnectionType) :
|
|||||||
|
|
||||||
open fun bind(channel: Channel) {
|
open fun bind(channel: Channel) {
|
||||||
scope = CoroutineScope(channel.eventLoop().asCoroutineDispatcher() + SupervisorJob() + CoroutineExceptionHandler { coroutineContext, throwable ->
|
scope = CoroutineScope(channel.eventLoop().asCoroutineDispatcher() + SupervisorJob() + CoroutineExceptionHandler { coroutineContext, throwable ->
|
||||||
disconnect("Uncaught exception in one of connection' coroutines: $throwable")
|
|
||||||
LOGGER.fatal("Uncaught exception in one of $this coroutines", throwable)
|
LOGGER.fatal("Uncaught exception in one of $this coroutines", throwable)
|
||||||
|
disconnect("Uncaught exception in one of connection' coroutines: $throwable")
|
||||||
})
|
})
|
||||||
|
|
||||||
channel.config().setOption(ChannelOption.TCP_NODELAY, true)
|
channel.config().setOption(ChannelOption.TCP_NODELAY, true)
|
||||||
|
Loading…
Reference in New Issue
Block a user