(i pddlmZmZmZmZmZddlmZmZm Z erddl m Z ddl m Z ddlmZGddZy) ) TYPE_CHECKINGAnyDictUnioncast) FormattedEthSubscriptionResponse RPCEndpoint RPCResponse) AsyncWeb3)_AsyncPersistentMessageStream)PersistentConnectionProviderc~eZdZdZd dZedeeeffdZ de dede fdZ de deddfd Z dee effd Zd d Zy)PersistentConnectionz A class that houses the public API for interacting with the persistent connection via a `AsyncWeb3` instance instantiated with a `PersistentConnectionProvider` class. cp|j|_td|jj|_y)Nr )manager_managerrprovider)selfw3s `/var/www/br/venv/lib/python3.12/site-packages/web3/providers/persistent/persistent_connection.py__init__zPersistentConnection.__init__!s&  ;T]]=S=ST returncB|jjjS)z Return the active subscriptions on the persistent connection. :return: The active subscriptions on the persistent connection. :rtype: Dict[str, Any] )r_request_processoractive_subscriptionsrs r subscriptionsz"PersistentConnection.subscriptions%s}}//DDDrmethodparamscVK|jj||d{S7w)a Make a request to the persistent connection and return the response. This method does not process the response as it would when invoking a method via the appropriate module on the `AsyncWeb3` instance, e.g. `w3.eth.get_block("latest")`. :param method: The RPC method, e.g. `eth_getBlockByNumber`. :param params: The RPC method parameters, e.g. `["0x1337", False]`. :return: The unprocessed response from the persistent connection. :rtype: RPCResponse N)r make_requestrrr s rr"z!PersistentConnection.make_request/s%]]//????s )')NcXK|jj||d{y7w)z Send a raw, unprocessed message to the persistent connection. :param method: The RPC method, e.g. `eth_getBlockByNumber`. :param params: The RPC method parameters, e.g. `["0x1337", False]`. :return: None N)rsendr#s rr%zPersistentConnection.send>s"mm  000s *(*cRK|jjd{S7w)a! Receive the next unprocessed response for a request from the persistent connection. :return: The next unprocessed response for a request from the persistent connection. :rtype: Union[RPCResponse, FormattedEthSubscriptionResponse] N)rrecvrs rr'zPersistentConnection.recvIs!]]''))))s '%'c6|jjS)z Asynchronous iterator that yields messages from the subscription message stream. :return: The subscription message stream. :rtype: _AsyncPersistentMessageStream )r_persistent_message_streamrs rprocess_subscriptionsz*PersistentConnection.process_subscriptionsTs}}7799r)rzAsyncWeb3[Any])rr )__name__ __module__ __qualname____doc__rpropertyrstrrrr r r"r%rrr'r*rrrrs UEtCH~EE @ @c @k @ 1 1c 1d 1 *E+/O"OP *:rrN)typingrrrrr web3.typesrr r web3.mainr web3.managerr web3.providers.persistentr rr1rrr7s9  @:@:r