// Lets consider we want to find the dryRun Status for describeRegions API
        boolean dryRunComplete = isDryRunComplete(() -> ec2Client.describeRegions(r -> r.regionNames(Region.US_EAST_1.id()).dryRun(true)));

    // Write a generic Private API that takes in any EC2 Operation , make sure dryRun flag is set and extract the Error response
    private boolean isDryRunComplete(Supplier<Ec2Response> dryRunOp) {
        Ec2Response ec2Response = null;
        try {
            ec2Response = dryRunOp.get();
        } catch (Ec2Exception exception) {
            AwsErrorDetails awsErrorDetails = exception.awsErrorDetails();
            if ("AuthFailure".equals(awsErrorDetails.errorCode())) {
                return false;
            }
            if ("DryRunOperation".equals(awsErrorDetails.errorCode())) {
                return true;
            }
            throw exception;
        }
        throw new IllegalStateException("Unable to get dryRun status for ec2Response:  " + ec2Response);
    }

        Boolean isDryRunComplete = asyncClient.describeRegions(r -> r.regionNames(Region.US_EAST_1.id())
                                                                     .dryRun(true))
                                              .handle((resp, e) -> isDryRunCompleted(e))
                                              .join();

    // Write a generic Private API that gets the DryRun status from the exception
    private static Boolean isDryRunCompleted(Throwable exceptionCaught) {
        if(exceptionCaught.getCause() instanceof Ec2Exception){
            Ec2Exception exception = (Ec2Exception) exceptionCaught.getCause();
            AwsErrorDetails awsErrorDetails = exception.awsErrorDetails();
            if ("AuthFailure".equals(awsErrorDetails.errorCode())) {
                return false;
            }
            if ("DryRunOperation".equals(awsErrorDetails.errorCode())) {
                return true;
            }
        }
        throw new IllegalStateException(exceptionCaught.getCause());
    }