BaseGraphQLTransportWSHandler
Constructor:
Signature:
Parameters:
-
schema:
- Type
-
BaseSchema
-
debug:
- Type
-
bool
-
connection_init_wait_timeout:
- Type
-
timedelta
Methods:
-
get_context
Return the operations context.
Signature:
-
get_root_value
Return the schemas root value.
Signature:
-
send_json
Send the data JSON encoded to the WebSocket client.
Signature:
Parameters:
-
data:
- Type
-
dict
-
-
close
Close the WebSocket with the passed code and reason.
Signature:
Parameters:
-
code:
- Type
-
int
-
reason:
- Type
-
str
-
-
handle_request
Handle the request this instance was created for.
Signature:
-
handle
Signature:
-
shutdown
Signature:
-
on_request_accepted
Signature:
-
handle_connection_init_timeout
Signature:
-
handle_task_exception
Signature:
Parameters:
-
error:
- Type
-
Exception
-
-
handle_message
Signature:
Parameters:
-
message:
- Type
-
dict
-
-
handle_connection_init
Signature:
Parameters:
-
message:
- Type
-
ConnectionInitMessage
-
-
handle_ping
Signature:
Parameters:
-
message:
- Type
-
PingMessage
-
-
handle_pong
Signature:
Parameters:
-
message:
- Type
-
PongMessage
-
-
handle_subscribe
Signature:
Parameters:
-
message:
- Type
-
SubscribeMessage
-
-
operation_task
The operation task’s top level method. Cleans-up and de-registers the operation once it is done.
Signature:
Parameters:
-
result_source:
- Type
-
AsyncGenerator
-
operation:
- Type
-
Operation
-
-
handle_async_results
Signature:
Parameters:
-
result_source:
- Type
-
AsyncGenerator
-
operation:
- Type
-
Operation
-
-
forget_id
Signature:
Parameters:
-
id:
- Type
-
str
-
-
handle_complete
Signature:
Parameters:
-
message:
- Type
-
CompleteMessage
-
-
handle_invalid_message
Signature:
Parameters:
-
error_message:
- Type
-
str
-
-
send_message
Signature:
Parameters:
-
message:
- Type
-
GraphQLTransportMessage
-
-
cleanup_operation
Signature:
Parameters:
-
operation_id:
- Type
-
str
-
-
reap_completed_tasks
Await tasks that have completed.
Signature:
Attributes:
-
task_logger:
- Type
-
logging.Logger
-
schema:
-
debug:
-
connection_init_wait_timeout:
-
connection_init_timeout_task:
- Type
-
asyncio.Task | None
-
connection_init_received:
-
connection_acknowledged:
-
connection_timed_out:
-
operations:
- Type
-
Dict[str, Operation]
-
completed_tasks:
- Type
-
List[asyncio.Task]
-
connection_params:
- Type
-
Dict[str, Any] | None