1 files changed, 3 insertions, 6 deletions
diff --git a/src/stream_mqtt.h b/src/stream_mqtt.h
index 458f2ac..9023430 100644
--- a/src/stream_mqtt.h
+++ b/src/stream_mqtt.h
@@ -3,13 +3,10 @@
 
 #include "stream.h"
 
-int64_t StreamReadMqttString(char **s, size_t *len, Stream *stream);
-int64_t StreamWriteMqttString(const char *s, int len, Stream *stream);
+#include <bstrlib/bstrlib.h>
 
-struct StringBuf;
-
-int64_t StreamReadMqttStringBuf(struct StringBuf *buf, Stream *stream);
-int64_t StreamWriteMqttStringBuf(const struct StringBuf *buf, Stream *stream);
+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);