blob: 458f2ac41741aa71c81c4e1b9b548d978e015333 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
#ifndef STREAM_MQTT_H
#define STREAM_MQTT_H
#include "stream.h"
int64_t StreamReadMqttString(char **s, size_t *len, Stream *stream);
int64_t StreamWriteMqttString(const char *s, int len, Stream *stream);
struct StringBuf;
int64_t StreamReadMqttStringBuf(struct StringBuf *buf, Stream *stream);
int64_t StreamWriteMqttStringBuf(const struct StringBuf *buf, Stream *stream);
int64_t StreamReadRemainingLength(size_t *remainingLength, Stream *stream);
int64_t StreamWriteRemainingLength(size_t remainingLength, Stream *stream);
#endif
|
