1 files changed, 17 insertions, 0 deletions
diff --git a/src/stream_mqtt.h b/src/stream_mqtt.h
new file mode 100644
index 0000000..458f2ac
--- /dev/null
+++ b/src/stream_mqtt.h
@@ -0,0 +1,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