public boolean nextInterval()

in java/ws-server/src/main/java/com/epam/deltix/tbwg/webapp/services/grafana/AggregatorImpl.java [67:94]

• 28 lines of code
• 11 McCabe index (conditional complexity)

    public boolean nextInterval(MessageSource<InstrumentMessage> messageSource, IntervalEntry intervalEntry) {
        intervalEntry.reuse();
        intervalEntry.setTimestamp(current);
        if (next()) {
            rawValues.clear();
            do {
                if (messageSource.getMessage() != null && messageSource.getMessage().getTimeStampMs() != Long.MIN_VALUE) {
                    RawMessage rawMessage = (RawMessage) messageSource.getMessage();
                    if (rawMessage.getTimeStampMs() >= currentFirst && rawMessage.getTimeStampMs() < currentLast) {
                        decoder.decode(rawMessage, rawValues);
                    } else if (rawMessage.getTimeStampMs() >= currentLast) {
                        break;
                    }
                }
                if (!messageSource.next()) {
                    cursorFinished = true;
                }
            } while (!cursorFinished && messageSource.getMessage().getTimeStampMs() < currentLast);
            rawValues.forEach((field, values) -> {
                if (!values.getList().isEmpty()) {
                    intervalEntry.put(field, function.aggregate(values.getList()));
                }
            });
            return true;
        } else {
            return false;
        }
    }