add flush_send_msg() implementation

2024-05-03 00:03:02 +02:00
parent dba3b458ba
commit 5fdad484f4
1 changed files with 5 additions and 0 deletions
--- 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
    '''