fix typing

Author: sleepyStick

test/asynchronous/helpers.py

@@ -422,19 +422,3 @@ async def run(self):
         except BaseException as exc:
             self.exc = exc
             raise
-
-
-def create_barrier(N_TASKS, timeout: float | None = None):
-    return threading.Barrier(N_TASKS, timeout=timeout)
-
-
-def async_create_barrier(N_TASKS, timeout: float | None = None):
-    return asyncio.Barrier(N_TASKS)
-
-
-def barrier_wait(barrier, timeout: float | None = None):
-    barrier.wait()
-
-
-async def async_barrier_wait(barrier, timeout: float | None = None):
-    await asyncio.wait_for(barrier.wait(), timeout=timeout)

test/helpers.py

@@ -422,19 +422,3 @@ def run(self):
         except BaseException as exc:
             self.exc = exc
             raise
-
-
-def create_barrier(N_TASKS, timeout: float | None = None):
-    return threading.Barrier(N_TASKS, timeout=timeout)
-
-
-def create_barrier(N_TASKS, timeout: float | None = None):
-    return asyncio.Barrier(N_TASKS)
-
-
-def barrier_wait(barrier, timeout: float | None = None):
-    barrier.wait()
-
-
-def barrier_wait(barrier, timeout: float | None = None):
-    asyncio.wait_for(barrier.wait(), timeout=timeout)

test/utils.py

@@ -1073,3 +1073,19 @@ def create_async_event():
 
 def create_event():
     return threading.Event()
+
+
+def async_create_barrier(N_TASKS, timeout: float | None = None):
+    return asyncio.Barrier(N_TASKS)
+
+
+def create_barrier(N_TASKS, timeout: float | None = None):
+    return threading.Barrier(N_TASKS, timeout=timeout)
+
+
+async def async_barrier_wait(barrier, timeout: float | None = None):
+    await asyncio.wait_for(barrier.wait(), timeout=timeout)
+
+
+def barrier_wait(barrier, timeout: float | None = None):
+    barrier.wait()