csv_reader_iterator.cpp

Go to the documentation of this file.

 
#include "csv_reader.hpp"
 
namespace csv {
    CSV_INLINE CSVReader::iterator CSVReader::begin() {
        if (this->records->empty()) {
            this->read_csv_worker = std::thread(&CSVReader::read_csv, this, internals::ITERATION_CHUNK_SIZE);
            this->read_csv_worker.join();
 
            // Still empty => return end iterator
            if (this->records->empty()) return this->end();
        }
 
        this->_n_rows++;
        CSVReader::iterator ret(this, this->records->pop_front());
        return ret;
    }
 
    CSV_INLINE HEDLEY_CONST CSVReader::iterator CSVReader::end() const noexcept {
        return CSVReader::iterator();
    }
 
    // CSVReader::iterator //
 
    CSV_INLINE CSVReader::iterator::iterator(CSVReader* _daddy, CSVRow&& _row) :
        daddy(_daddy) {
        row = std::move(_row);
    }
 
    CSV_INLINE CSVReader::iterator& CSVReader::iterator::operator++() {
        if (!daddy->read_row(this->row)) {
            this->daddy = nullptr; // this == end()
        }
 
        return *this;
    }
 
    CSV_INLINE CSVReader::iterator CSVReader::iterator::operator++(int) {
        auto temp = *this;
        if (!daddy->read_row(this->row)) {
            this->daddy = nullptr; // this == end()
        }
 
        return temp;
    }
}