Fasten transaction broadcast with asyncio.gather

src/sakia/core/net/api/bma/access.py

@@ -307,9 +307,14 @@ class BmaAccess(QObject):
                 logging.debug("Trying to connect to : " + node.pubkey)
                 conn_handler = node.endpoint.conn_handler()
                 req = request(conn_handler, **req_args)
-                try:
-                    reply = await req.post(**post_args)
+                reply = asyncio.ensure_future(req.post(**post_args))
                 replies.append(reply)
+            self._invalidate_cache(request)
+        else:
+            raise NoPeerAvailable("", len(nodes))
+
+        try:
+            result = await asyncio.gather(*replies)
         except ValueError as e:
             if '404' in str(e) or '400' in str(e):
                 raise
@@ -317,7 +322,4 @@ class BmaAccess(QObject):
             pass
         except asyncio.TimeoutError:
             pass
-            self._invalidate_cache(request)
-        else:
-            raise NoPeerAvailable("", len(nodes))
-        return tuple(replies)
+        return tuple(result)