library/cpp/ucompress/reader.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

#pragma once

#include <util/generic/buffer.h>
#include <util/stream/walk.h>


namespace NBlockCodecs {
    struct ICodec;
}

namespace NUCompress {
    class TDecodedInput: public IWalkInput {
    public:
        TDecodedInput(IInputStream* in);
        ~TDecodedInput() override;

    private:
        size_t DoUnboundedNext(const void** ptr) override;

    private:
        IInputStream* const S_;
        const NBlockCodecs::ICodec* C_ = nullptr;
        TBuffer D_;
    };
}