From 5fdad484f480860bc96899b54fb078454eee5a83 Mon Sep 17 00:00:00 2001 From: Stefan Allius Date: Fri, 3 May 2024 00:03:02 +0200 Subject: [PATCH] add flush_send_msg() implementation --- app/src/gen3/connection_g3.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/app/src/gen3/connection_g3.py b/app/src/gen3/connection_g3.py index c93156e..3ac1e7c 100644 --- a/app/src/gen3/connection_g3.py +++ b/app/src/gen3/connection_g3.py @@ -29,6 +29,11 @@ class ConnectionG3(AsyncStream, Talent): async def async_publ_mqtt(self) -> None: pass + async def flush_send_msg(self) -> None: + self.writer.write(self._send_buffer) + await self.writer.drain() + self._send_buffer = bytearray(0) + ''' Our private methods '''