aboutsummaryrefslogtreecommitdiff
path: root/src/stream_mqtt.h
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