(self)
| 31 | print(f"Error in receive loop: {e}") |
| 32 | |
| 33 | async def run(self): |
| 34 | await self.connect() |
| 35 | if self.reader and self.writer: |
| 36 | asyncio.create_task(self.receive_loop()) |
| 37 | while True: |
| 38 | await self.send("ping from client") |
| 39 | await asyncio.sleep(2) |
| 40 | |
| 41 | if __name__ == "__main__": |
| 42 | SOCKET_PATH = "/tmp/pi-webrtc-ipc.sock" |