From 7565a66d9084c71f499be3f99d3e70e3368c1f00 Mon Sep 17 00:00:00 2001 From: marios8543 Date: Wed, 18 Oct 2023 21:04:51 +0300 Subject: fix emit_message mechanism --- backend/src/localplatform/localsocket.py | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'backend/src/localplatform') diff --git a/backend/src/localplatform/localsocket.py b/backend/src/localplatform/localsocket.py index 2ef039ee..93b1ea18 100644 --- a/backend/src/localplatform/localsocket.py +++ b/backend/src/localplatform/localsocket.py @@ -18,6 +18,7 @@ class UnixSocket: self.socket = None self.reader = None self.writer = None + self.server_writer = None async def setup_server(self): self.socket = await asyncio.start_unix_server(self._listen_for_method_call, path=self.socket_addr, limit=BUFFER_LIMIT) @@ -90,8 +91,14 @@ class UnixSocket: writer.write(message.encode("utf-8")) await writer.drain() + + async def write_single_line_server(self, message: str): + if self.server_writer is None: + return + await self._write_single_line(self.server_writer, message) async def _listen_for_method_call(self, reader: asyncio.StreamReader, writer: asyncio.StreamWriter): + self.server_writer = writer while True: def _(task: asyncio.Task[str|None]): -- cgit v1.2.3