Always call the onDisconnect listeners during shutdown
This commit is contained in:
parent
c587088095
commit
4a3c5cf703
@ -30,6 +30,8 @@ import dorkbox.network.connection.Listener.OnDisconnected;
|
|||||||
public final
|
public final
|
||||||
class OnDisconnectedManager<C extends Connection> extends ConcurrentManager<C, OnDisconnected<C>> {
|
class OnDisconnectedManager<C extends Connection> extends ConcurrentManager<C, OnDisconnected<C>> {
|
||||||
|
|
||||||
|
private static final AtomicBoolean disconnectBoolean = new AtomicBoolean(false);
|
||||||
|
|
||||||
public
|
public
|
||||||
OnDisconnectedManager(final Logger logger) {
|
OnDisconnectedManager(final Logger logger) {
|
||||||
super(logger);
|
super(logger);
|
||||||
@ -39,8 +41,9 @@ class OnDisconnectedManager<C extends Connection> extends ConcurrentManager<C, O
|
|||||||
* @return true if a listener was found, false otherwise
|
* @return true if a listener was found, false otherwise
|
||||||
*/
|
*/
|
||||||
public
|
public
|
||||||
boolean notifyDisconnected(final C connection, final AtomicBoolean shutdown) {
|
boolean notifyDisconnected(final C connection) {
|
||||||
return doAction(connection, shutdown);
|
// we override the boolean, because we ALWAYS want to call the disconnect listeners!
|
||||||
|
return doAction(connection, disconnectBoolean);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
Loading…
Reference in New Issue
Block a user