project2/compression/decompressStream.cpp


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
26
27
28
29
30

#include "stream.h"
#include "decompressor.h"
#include "scripts.h"
#include "variables.h"
#include "scriptStorage.h"

class DecompressStream : public Stream {
	public:
		DecompressStream(ScriptNodePtr p) :
			Stream(p),
			method(p, "method")
		{
			p->script.lock()->loader.addLoadTarget(p, Storer::into<StreamFactory>(&stream));
		}

		void runStream(const Sink & sink, ExecContext * ec) const
		{
			DecompressorPtr decomp = DecompressorFactory::createNew(method(ec));
			stream->runStream([&](const char * data, size_t len) -> size_t {
					decomp->decompress(data, len, sink);
					return len;
				}, ec);
		}

		StreamPtr stream;
		const Variable method;
};

NAMEDFACTORY("decompstream", DecompressStream, StreamFactory);