chunkstream.hpp

Go to the documentation of this file.

 
#ifndef __JOIN_CHUNKTREAM_HPP__
#define __JOIN_CHUNKTREAM_HPP__
 
// libjoin.
#include <join/streambuf.hpp>
 
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