Make sure Future get notified before event is fired. See #254
This commit is contained in:
parent
d2d859d22c
commit
778f4a3cbc
|
@ -110,13 +110,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