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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
#pragma once
#include "Core/Io/Stream.h"
namespace storm {
namespace server {
STORM_PKG(core.lang.server);
/**
* Fillable in-memory stream used for parsing of messages.
*/
class BufStream : public RIStream {
STORM_CLASS;
public:
// Create.
STORM_CTOR BufStream();
// Copy.
BufStream(const BufStream &o);
// Deep copy.
void STORM_FN deepCopy(CloneEnv *env);
// More data?
virtual Bool STORM_FN more();
// Read.
using RIStream::read;
virtual Buffer STORM_FN read(Buffer to);
// Peek.
using RIStream::peek;
virtual Buffer STORM_FN peek(Buffer to);
// Seek.
virtual void STORM_FN seek(Word to);
// Tell.
virtual Word STORM_FN tell();
// Current length.
virtual Word STORM_FN length();
// Get random access version.
virtual RIStream *STORM_FN randomAccess();
// Output.
void STORM_FN toS(StrBuf *to) const;
// Append more data. May discard any data which has already been read.
void STORM_FN append(Buffer data);
// Find the first occurrence of 'b' from 'tell()'. Returns the number of bytes to read
// before reaching it, or the remaining number of bytes if none is found.
Nat STORM_FN findByte(Byte b) const;
private:
// Data.
Buffer data;
// Position.
Nat pos;
// Re-allocate 'data' so that it can hold at least 'count' more bytes.
void realloc(Nat count);
};
}
}
|
