public void consume()

in src/main/java/org/apache/skywalking/banyandb/v1/client/BulkWriteProcessor.java [86:103]

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

        public void consume(final List data) {
            if (data.size() >= maxBulkSize) {
                // The data#size actually wouldn't over the maxBulkSize due to the DataCarrier channel's max size.
                // This is just to preventing unexpected case and avoid confusion about dropping into else section.
                bulkWriteProcessor.flush(data);
                lastFlushTimestamp = System.currentTimeMillis();
            } else {
                data.forEach(element -> {
                    cachedData.add(element);
                    if (cachedData.size() >= maxBulkSize) {
                        // Flush and re-init.
                        bulkWriteProcessor.flush(cachedData);
                        cachedData = new ArrayList(maxBulkSize);
                        lastFlushTimestamp = System.currentTimeMillis();
                    }
                });
            }
        }