From 8cfde1a09678b3e33c32eeb3d3aad1cb0ffd3842 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tom=C3=A1=C5=A1=20Chaloupka?= Date: Fri, 11 Oct 2024 16:57:49 +0200 Subject: [PATCH] Update dependency --- dub.sdl | 1 + source/mqttd/client.d | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/dub.sdl b/dub.sdl index a7d2d8c..0a391c9 100644 --- a/dub.sdl +++ b/dub.sdl @@ -6,4 +6,5 @@ license "BSL-1.0" targetType "library" dependency "vibe-d:tls" version="~>0.8" +dependency "vibe-d:stream" version="~>0.8" dependency "vibe-d:utils" version="~>0.8" diff --git a/source/mqttd/client.d b/source/mqttd/client.d index 1c2baaa..ed0681b 100644 --- a/source/mqttd/client.d +++ b/source/mqttd/client.d @@ -41,6 +41,7 @@ import std.string : format, representation; import std.traits; import std.typecons : Flag, No, Yes; +import vibe.container.ringbuffer : RingBuffer; import vibe.core.concurrency; import vibe.core.log; import vibe.core.net: TCPConnection; @@ -1120,7 +1121,7 @@ private: Session _session; Task _listener, _dispatcher; Serializer!(Appender!(ubyte[])) _sendBuffer; - FixedRingBuffer!ubyte _readBuffer; + RingBuffer!ubyte _readBuffer; ubyte[] _packetBuffer; bool _disconnecting; Timer _conAckTimer, _subAckTimer, _unsubAckTimer, _pingReqTimer, _pingRespTimer, _reconnectTimer;