diff --git a/tests/pubsub/utils.py b/tests/pubsub/utils.py
index 66916613..e406536e 100644
--- 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)