o tBh@sFddlZddlmZmZmZmZddlmZmZGdddej Z dS)N)AnyAsyncGeneratorDictOptional) DocumentNodeExecutionResultc @seZdZejddZejddZej  ddedee e e fdee d e fd d Z ej  ddedee e e fdee d ee dffd d ZdS)AsyncTransportc td)z>Coroutine used to create a connection to the specified addressz9Any AsyncTransport subclass must implement connect methodNotImplementedErrorselfrt/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/gql/transport/async_transport.pyconnectzAsyncTransport.connectcr )z1Coroutine used to Close an established connectionz7Any AsyncTransport subclass must implement close methodr r rrrcloserzAsyncTransport.closeNdocumentvariable_valuesoperation_namereturncr )zVExecute the provided document AST for either a remote or local GraphQL Schema.z9Any AsyncTransport subclass must implement execute methodr r rrrrrrexecutes zAsyncTransport.executecCstd)zSend a query and receive the results using an async generator The query can be a graphql query, mutation or subscription The results are sent as an ExecutionResult object z;Any AsyncTransport subclass must implement subscribe methodr rrrr subscribe#s zAsyncTransport.subscribe)NN)__name__ __module__ __qualname__abcabstractmethodrrrrrstrrrrrrrrrrrs:     r) rtypingrrrrgraphqlrrABCrrrrrs