Make sure Future get notified before event is fired. See #254
This commit is contained in:
parent
bb0e39bd78
commit
16c3d4bc3c
|
@ -114,13 +114,13 @@ class OioWorker extends AbstractOioWorker<OioSocketChannel> {
|
|||
a.getBytes(a.readerIndex(), out, length);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
future.setSuccess();
|
||||
if (iothread) {
|
||||
fireWriteComplete(channel, length);
|
||||
} else {
|
||||
fireWriteCompleteLater(channel, length);
|
||||
}
|
||||
future.setSuccess();
|
||||
|
||||
} catch (Throwable t) {
|
||||
// Convert 'SocketException: Socket closed' to
|
||||
|
|
Loading…
Reference in New Issue
Block a user