INNER CODE UNIT · Python
complete
psevensas/DjangoChannelsGraphqlWs · channels_graphql_ws/client.py:239
async def complete(self, op_id):
"""Complete GraphQL request.
Args:
op_id: Operation id that should be completed.
"""
msg_type = "complete" if self._subprotocol == "graphql-transport-ws" else "stop"
message = {"type": msg_type, "id": op_id}
await self._transport.send(message)
async def finalize(self):
"""Disconnect and wait the transport to finish gracefully."""
await self._transport.disconnect()
self._is_connected = False
async def wait_response(self, response_checker, timeout=None):
"""Wait for particular response skipping all intermediate ones.