Method fetchWebEndpoint

java/lib/src/main/java/io/github/ccxt/Exchange.java:7579–7658

(Object method, Object endpointMethod, Object returnAsJson2, Object... optionalArgs)

    }

    public java.util.concurrent.CompletableFuture<Object> fetchWebEndpoint(Object method, Object endpointMethod, Object returnAsJson2, Object... optionalArgs)
    {
        final Object returnAsJson3 = returnAsJson2;
        return java.util.concurrent.CompletableFuture.supplyAsync(() -> {
            Object returnAsJson = returnAsJson3;
            Object startRegex = Helpers.getArg(optionalArgs, 0, null);
            Object endRegex = Helpers.getArg(optionalArgs, 1, null);
            Object errorMessage = "";
            Object options = this.safeValue(this.options, method, new java.util.HashMap<String, Object>() {{}});
            Object muteOnFailure = this.safeBool(options, "webApiMuteFailure", true);
            try
            {
                // if it was not explicitly disabled, then don't fetch
                if (Helpers.isTrue(!Helpers.isEqual(this.safeBool(options, "webApiEnable", true), true)))
                {
                    return null;
                }
                Object maxRetries = this.safeValue(options, "webApiRetries", 10);
                Object response = null;
                Object retry = 0;
                Object shouldBreak = false;
                while (Helpers.isLessThan(retry, maxRetries))
                {
                    try
                    {
                        response = ((java.util.concurrent.CompletableFuture<Object>)Helpers.callDynamically(this, endpointMethod, new Object[] { new java.util.HashMap<String, Object>() {{}} })).join();
                        shouldBreak = true;
                        break;
                    } catch(Exception e)
                    {
                        retry = Helpers.add(retry, 1);
                        if (Helpers.isTrue(Helpers.isEqual(retry, maxRetries)))
                        {
                            throw e;
                        }
                    }
                    if (Helpers.isTrue(shouldBreak))
                    {
                        break; // this is needed because of GO
                    }
                }
                Object content = response;
                if (Helpers.isTrue(!Helpers.isEqual(startRegex, null)))
                {
                    Object splitted_by_start = Helpers.split(content, startRegex);
                    content = Helpers.GetValue(splitted_by_start, 1); // we need second part after start
                }
                if (Helpers.isTrue(!Helpers.isEqual(endRegex, null)))
                {
                    Object splitted_by_end = Helpers.split(content, endRegex);
                    content = Helpers.GetValue(splitted_by_end, 0); // we need first part after start
                }
                if (Helpers.isTrue(Helpers.isTrue(returnAsJson) && Helpers.isTrue(((content instanceof String)))))
                {
                    Object jsoned = this.parseJson(((String)content).trim()); // content should be trimmed before json parsing
                    if (Helpers.isTrue(jsoned))
                    {
                        return jsoned;  // if parsing was not successfull, exception should be thrown