File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
web3/providers/persistent Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -39,7 +39,7 @@ def subscriptions(self) -> Dict[str, Any]:
39
39
40
40
async def make_request (self , method : RPCEndpoint , params : Any ) -> RPCResponse :
41
41
"""
42
- Make a request to the persistent connection, returning the response. This method
42
+ Make a request to the persistent connection and return the response. This method
43
43
does not process the response as it would when invoking a method via the
44
44
appropriate module on the `AsyncWeb3` instance,
45
45
e.g. `w3.eth.get_block("latest")`.
@@ -68,15 +68,17 @@ async def recv(self) -> RPCResponse:
68
68
Receive the next unprocessed response for a request from the persistent
69
69
connection.
70
70
71
- :return: RPCResponse: The raw, unprocessed message from the
72
- persistent connection.
71
+ :return: The next unprocessed response for a request from the persistent
72
+ connection.
73
+ :rtype: RPCResponse
73
74
"""
74
75
return await self ._manager .recv ()
75
76
76
77
def process_subscriptions (self ) -> "_AsyncPersistentMessageStream" :
77
78
"""
78
79
Asynchronous iterator that yields messages from the subscription message stream.
79
80
80
- :return: _AsyncPersistentMessageStream: The subscription message stream.
81
+ :return: The subscription message stream.
82
+ :rtype: _AsyncPersistentMessageStream
81
83
"""
82
84
return self ._manager ._persistent_message_stream ()
You can’t perform that action at this time.
0 commit comments