Description
Looks to be a race condition where non final values have might not be set and close() is called on the channel group.
public void close() {
|
doCancelRead(this, null);
|
doCancelWrite(this, null);
|
key.cancel(); // NPE if key == null
|
currentRegistrations.getAndDecrement();
|
/*
|
* Actual de-registration from the selector will happen asynchronously.
|
*/
|
selector.wakeup();
|
}
|
Attachments
Issue Links
- is duplicated by
-
JAVA-3733 Failing reactive streams integration test
-
- Closed
-