chunk_stream.hpp

Go to the documentation of this file.

 
#ifndef JOIN_SERVICES_CHUNK_STREAM_HPP
#define JOIN_SERVICES_CHUNK_STREAM_HPP
 
// libjoin.
#include <join/streambuf.hpp>
 
// C++.
#include <iostream>
#include <memory>
 
namespace join
{
    class Chunkstreambuf : public StreambufDecorator
    {
    public:
        Chunkstreambuf (std::streambuf* streambuf, bool own = false);
 
        Chunkstreambuf (std::streambuf* streambuf, std::streamsize chunksize, bool own = false);
 
        Chunkstreambuf (const Chunkstreambuf& other) = delete;
 
        Chunkstreambuf& operator= (const Chunkstreambuf& other) = delete;
 
        Chunkstreambuf (Chunkstreambuf&& other);
 
        Chunkstreambuf& operator= (Chunkstreambuf&& other);
 
        virtual ~Chunkstreambuf ();
 
    protected:
        virtual int_type underflow () override;
 
        virtual int_type overflow (int_type c = traits_type::eof ()) override;
 
        virtual int_type sync () override;
 
        std::streamsize _chunksize = 16384;
 
        std::unique_ptr<char[]> _buf;
    };
 
    class Chunkstream : public std::iostream
    {
    public:
        Chunkstream (std::iostream& stream);
 
        Chunkstream (std::iostream& stream, std::streamsize chunksize);
 
        Chunkstream (const Chunkstream& other) = delete;
 
        Chunkstream& operator= (const Chunkstream& other) = delete;
 
        Chunkstream (Chunkstream&& other);
 
        Chunkstream& operator= (Chunkstream&& other);
 
        virtual ~Chunkstream () = default;
 
    protected:
        Chunkstreambuf _chunkbuf;
    };
}
 
#endif