Lines Matching refs:client
57 async def _sender(client, send_queue):
58 assert client.state == websockets.protocol.OPEN, logging.error(f'Client state of _sender is: {client.state}')
63 await client.close(reason='close')
65 await client.send(json.dumps(send_message))
68 async def _receiver(client, received_queue):
69 assert client.state == websockets.protocol.OPEN, logging.error(f'Client state of _receiver is: {client.state}')
72 response = await client.recv()
107 client = connect(f'ws://localhost:{self.connect_server_port}',
110 return client
113 client = connect(f'ws://localhost:{self.debugger_server_port}',
116 return client
118 async def _receiver_of_connect_server(self, client, receive_queue, taskpool, pid):
119 assert client.state == websockets.protocol.OPEN, \
120 logging.error(f'Client state of _receiver_of_connect_server is: {client.state}')
124 response = await client.recv()
129 # The debugger server client is only responsible for adding and removing instances