public void executeAsyncHandler()

in impl/src/main/java/org/apache/rocketmq/remoting/common/ResponseFuture.java [68:79]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    public void executeAsyncHandler() {
        if (asyncHandler != null) {
            if (this.asyncHandlerExecuted.compareAndSet(false, true)) {
                if (cause != null) {
                    asyncHandler.onFailure(requestCommand, cause);
                } else {
                    assert responseCommand != null;
                    asyncHandler.onSuccess(responseCommand);
                }
            }
        }
    }