Commit 17f16de3 authored by Mygod's avatar Mygod

Delegate register exceptions to caller

parent 0ec69f23
...@@ -55,7 +55,7 @@ class ChannelMonitor : Thread("ChannelMonitor") { ...@@ -55,7 +55,7 @@ class ChannelMonitor : Thread("ChannelMonitor") {
pendingRegistrations.poll()!!.apply { pendingRegistrations.poll()!!.apply {
try { try {
result.complete(registerInternal(channel, ops, listener)) result.complete(registerInternal(channel, ops, listener))
} catch (e: ClosedChannelException) { } catch (e: Exception) {
result.completeExceptionally(e) result.completeExceptionally(e)
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment