Add one_to_all_connect

2019-07-18 19:39:57 +08:00 · 2019-07-18 19:39:57 +08:00 · a26c7783d6
commit a26c7783d6
parent 404dc67e83
1 changed files with 5 additions and 0 deletions
--- a/tests/pubsub/utils.py
+++ b/tests/pubsub/utils.py
@ -122,3 +122,8 @@ async def connect_some(hosts, degree):
    #         await connect(host, neighbor)

    #         j += 1
+
+async def one_to_all_connect(hosts, central_host_index):
+    for i, host in enumerate(hosts):
+        if i != central_host_index:
+            await connect(hosts[central_host_index], host)