remove flush_send_msg()
This commit is contained in:
@@ -29,11 +29,6 @@ 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
|
||||
'''
|
||||
|
||||
Reference in New Issue
Block a user