Phants Client for Redis™*
|
Public Member Functions | |
MessageParser (ResponseProcessor responseProcessor) | |
void | SimpleString (string s) |
void | Error (string error) |
void | Integer (long i) |
void | BulkStringBegin (int size) |
void | BulkStringData (byte[] data, int offset, int numBytes) |
void | BulkStringDone () |
void | ArrayBegin (int size) |
void | ArrayDone () |
This class serves as a concrete implementation of the RespParser interface. It handles parsing of redis subscription methods. Since messages use a fixed format, state is tracked and everything is parsed into a specific structure.
|
inline |
MessageParser constructor.
responseProcessor | After messages are received and parsed, they are passed on to this ResponseProcessor. |
|
inline |
Called at the start of a RESP Array.
size | The number of elements in the array being parsed. |
Implements ArrayParser.
|
inline |
Called at the end of a RESP Array.
Implements ArrayParser.
|
inline |
Called at the start of a RESP Bulk String.
size | The length of the string being parsed. |
Implements BulkStringParser.
|
inline |
Called when a block of string data has been read.
Since RESP Bulk Strings can be up to 512MB in length, this interface was designed to handle data in chunks (typically sent over a network). This method will be called as many times is as necessary to transfer the whole Bulk String.
data | A buffer containing the block of new bytes. |
offset | The zero-based offset into data where the new bytes are stored. |
numBytes | The number of bytes read. |
Implements BulkStringParser.
|
inline |
Called after the last byte(s) of a Bulk String have been parsed.
Implements BulkStringParser.
|
inline |
Called when an Error has been parsed.
error | The error string that was parsed. |
Implements ErrorParser.
|
inline |
Called when an Integer has been parsed.
i | The value of the parsed Integer. |
Implements IntegerParser.
|
inline |
Called when a Simple String has been parsed.
s | The string that was parsed. |
Implements SimpleStringParser.