Update RequestManager.request_async

Author: dylanjw

web3/manager.py

@@ -1,5 +1,4 @@
 import logging
-import uuid
 
 from eth_utils import (
     is_list_like,
@@ -8,9 +7,6 @@
 from web3._utils.empty import (
     empty,
 )
-from web3._utils.threads import (
-    spawn,
-)
 from web3.datastructures import (
     NamedElementOnion,
 )
@@ -102,6 +98,26 @@ def _make_request(self, method, params):
                 )
             )
 
+    async def _make_async_request(self, method, params):
+        """TODO: Can this be made dry? Going for dumb solution for now.
+        """
+        for provider in self.providers:
+            request_func = provider.request_func(self.web3, tuple(self.middleware_stack))
+            self.logger.debug("Making request. Method: %s", method)
+            try:
+                return await request_func(method, params)
+            except CannotHandleRequest:
+                continue
+        else:
+            raise UnhandledRequest(
+                "No providers responded to the RPC request:\n"
+                "method:{0}\n"
+                "params:{1}\n".format(
+                    method,
+                    params,
+                )
+            )
+
     def request_blocking(self, method, params):
         """
         Make a synchronous request using the provider
@@ -113,14 +129,16 @@ def request_blocking(self, method, params):
 
         return response['result']
 
-    def request_async(self, raw_method, raw_params):
-        request_id = uuid.uuid4()
-        self.pending_requests[request_id] = spawn(
-            self.request_blocking,
-            raw_method=raw_method,
-            raw_params=raw_params,
-        )
-        return request_id
+    async def request_async(self, method, params):
+        """Ok breaking change to public API?
+        Maybe should be a new function "coro_request".
+        """
+        response = await self._make_async_request(method, params)
+
+        if "error" in response:
+            raise ValueError(response["error"])
+
+        return response['result']
 
     def receive_blocking(self, request_id, timeout=None):
         try: