blob: 902343053f9482c83f4a75af517f7a7c7624189a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
#ifndef STREAM_MQTT_H
#define STREAM_MQTT_H
#include "stream.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
|