private T withStagingRepositories()

in src/main/java/org/apache/sling/cli/impl/nexus/RepositoryService.java [112:125]


    private <T> T withStagingRepositories(Function<InputStreamReader, T> function) throws IOException {
        try (CloseableHttpClient client = httpClientFactory.newClient()) {
            HttpGet get = newGet("/service/local/staging/profile_repositories");
            try (CloseableHttpResponse response = client.execute(get)) {
                try (InputStream content = response.getEntity().getContent();
                     InputStreamReader reader = new InputStreamReader(content)) {
                    if (response.getStatusLine().getStatusCode() != 200) {
                        throw new IOException("Status line : " + response.getStatusLine());
                    }
                    return function.apply(reader);
                }
            }
        }
    }