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();
}
- is duplicated by
-
JAVA-3733 Failing reactive streams integration test
-
- Closed
-