InputStreamer.hh

#ifndef avro_InputStreamer_hh__
#define avro_InputStreamer_hh__

#include <iostream>
#include <stdint.h>

namespace avro {

    
class InputStreamer {

  public:

    virtual ~InputStreamer()
    { }

    virtual size_t readByte(uint8_t &byte) = 0;
    virtual size_t readWord(uint32_t &word) = 0;
    virtual size_t readLongWord(uint64_t &word) = 0;
    virtual size_t readBytes(void *bytes, size_t size) = 0;
};


    
class IStreamer : public InputStreamer {

  public:

    IStreamer(std::istream &is) :
        is_(is)
    {}

    size_t readByte(uint8_t &byte) {
        char val;
        is_.get(val);
        byte = val;
        return 1;
    }

    size_t readWord(uint32_t &word) {
        is_.read(reinterpret_cast<char *>(&word), sizeof(word));
        return is_.gcount();
    }

    size_t readLongWord(uint64_t &word) {
        is_.read(reinterpret_cast<char *>(&word), sizeof(word));
        return is_.gcount();
    }

    size_t readBytes(void *bytes, size_t size) {
        is_.read(reinterpret_cast<char *>(bytes), size);
        return is_.gcount();
    }

  private:

    std::istream &is_;
};

} // namespace avro

#endif