(self, message)
| 47 | return self._ws |
| 48 | |
| 49 | async def send(self, message): |
| 50 | rebuild = False |
| 51 | while not self.scan.stopped: |
| 52 | try: |
| 53 | ws = await self.ws(rebuild=rebuild) |
| 54 | message_str = json.dumps(message) |
| 55 | self.debug(f"Sending message of length {len(message_str)}") |
| 56 | await ws.send(message_str) |
| 57 | rebuild = False |
| 58 | break |
| 59 | except Exception as e: |
| 60 | self.warning(f"Error sending message: {e}, retrying") |
| 61 | await asyncio.sleep(1) |
| 62 | rebuild = True |
| 63 | |
| 64 | async def cleanup(self): |
| 65 | if self._ws is not None: |
no test coverage detected