private Struct getLastRecord()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/TBSinkTask.java [87:99]

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

    private Struct getLastRecord() {
        Struct record = null;
        long[] range = msgStream.getTimeRange(new InstrumentIdentity[0]);
        if (range != null) {
            RawMessageDeserializer deserializer = getDeserializer();
            try (TickCursor cursor = msgStream.select(range[1], new SelectionOptions(true, false, false))) {
                while (cursor.next()) {
                    record = deserializer.deserialize((RawMessage) cursor.getMessage());
                }
            }
        }
        return record;
    }