(self)
| 38 | |
| 39 | |
| 40 | async def connect(self): |
| 41 | self.websocket = await websockets.connect(self.uri) |
| 42 | print("Connected to TermNet server") |
| 43 | welcome = await self.websocket.recv() # consume welcome |
| 44 | _ = json.loads(welcome) |
| 45 | |
| 46 | async def send_and_stream_to_queue(self, message: str, queue: Queue): |
| 47 | """Stream responses to a queue that can be consumed by Flask""" |
no outgoing calls
no test coverage detected