ChunkedDataLoader.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/io/PodIoUtils.h"
#include "catapult/io/Stream.h"
#include "catapult/functions.h"
 
namespace catapult { namespace cache {
 
    template<typename TStorageTraits>
    class ChunkedDataLoader {
    public:
        explicit ChunkedDataLoader(io::InputStream& input) : m_input(input) {
            m_numRemainingEntries = io::Read64(input);
        }
 
    public:
        bool hasNext() const {
            return 0 != m_numRemainingEntries;
        }
 
        void next(uint64_t numRequestedEntries, typename TStorageTraits::DestinationType& destination) {
            numRequestedEntries = std::min(numRequestedEntries, m_numRemainingEntries);
            m_numRemainingEntries -= numRequestedEntries;
            while (numRequestedEntries--)
                TStorageTraits::LoadInto(TStorageTraits::Load(m_input), destination);
        }
 
    private:
        io::InputStream& m_input;
        uint64_t m_numRemainingEntries;
    };
}}