|
@ -25,7 +25,10 @@ class RPCClient(JSONRPC): |
|
|
async def send_and_wait(self, method, params, timeout=None): |
|
|
async def send_and_wait(self, method, params, timeout=None): |
|
|
# Raise incoming buffer size - presumably connection is trusted |
|
|
# Raise incoming buffer size - presumably connection is trusted |
|
|
self.max_buffer_size = 5000000 |
|
|
self.max_buffer_size = 5000000 |
|
|
self.send_json_request(method, id_=method, params=params) |
|
|
self.send_text(self.json_request_text(method, |
|
|
|
|
|
id_=method, |
|
|
|
|
|
params=params), |
|
|
|
|
|
False) |
|
|
|
|
|
|
|
|
future = asyncio.ensure_future(self.messages.get()) |
|
|
future = asyncio.ensure_future(self.messages.get()) |
|
|
for f in asyncio.as_completed([future], timeout=timeout): |
|
|
for f in asyncio.as_completed([future], timeout=timeout): |
|
|