public List fetchData()

in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timebase/RawMessageDataFeeder.java [88:112]

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

    public List<RawMessage> fetchData(int size) {
        lock.lock();
        try {
            if (!isFetchingStart.get()) {
                executor.execute(() -> {
                    try {
                        fetchDataStream();
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                });
            }
        } finally {
            lock.unlock();
        }

        if (queue.isEmpty()) {
            return Collections.emptyList();
        }

        List<RawMessage> result = new ArrayList<>();
        queue.drainTo(result, size);

        return result;
    }