Skip to content

Commit 786ab80

Browse files
committed
[broker-11] fix for code review
1 parent 75e206e commit 786ab80

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

src/main/java/com/ss/mqtt/broker/network/client/impl/AbstractMqttClientReleaseHandler.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -49,10 +49,6 @@ public abstract class AbstractMqttClientReleaseHandler<T extends AbstractMqttCli
4949
asyncActions = clientIdRegistry.unregister(clientId);
5050
}
5151

52-
if (asyncActions != null) {
53-
return asyncActions;
54-
}
55-
56-
return Mono.empty();
52+
return asyncActions;
5753
}
5854
}

0 commit comments

Comments
 (0)