public void flush()

in src/main/java/org/apache/skywalking/banyandb/v1/client/AbstractBulkWriteProcessor.java [123:142]

• 17 lines of code
• 3 McCabe index (conditional complexity)

    public void flush() {
        if (requests.isEmpty()) {
            return;
        }

        try {
            semaphore.acquire();
        } catch (InterruptedException e) {
            log.error("Interrupted when trying to get semaphore to execute bulk requests", e);
            return;
        }

        final List<Holder> batch = new ArrayList<>(requests.size());
        requests.drainTo(batch);
        final CompletableFuture<Void> future = doFlush(batch);
        future.whenComplete((v, t) -> semaphore.release());
        future.join();
        lastFlushTS = System.currentTimeMillis();

    }