private boolean consume()

in src/main/java/org/apache/skywalking/banyandb/commons/datacarrier/consumer/ConsumerThread.java [68:85]

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

    private boolean consume(List<T> consumeList) {
        for (DataSource dataSource : dataSources) {
            dataSource.obtain(consumeList);
        }

        if (!consumeList.isEmpty()) {
            try {
                consumer.consume(consumeList);
            } catch (Throwable t) {
                consumer.onError(consumeList, t);
            } finally {
                consumeList.clear();
            }
            return true;
        }
        consumer.nothingToConsume();
        return false;
    }