blob: a128524c8f8890ddcc2d9981fe586c0a5f487564 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
#ifndef STREAM_MQTT_H
#define STREAM_MQTT_H
#include "stream.h"
#include "stringstream.h"
#include <bstrlib/bstrlib.h>
int64_t StreamReadMqttString(bstring *buf, Stream *stream);
int64_t StreamWriteMqttString(const_bstring buf, Stream *stream);
int64_t StreamReadRemainingLength(size_t *remainingLength, Stream *stream);
int64_t StreamWriteRemainingLength(size_t remainingLength, Stream *stream);
#endif
|