Merge pull request #24 from dfseifert/main

fix: correct typo in function name and add compatibility alias

Author: pyper-dev

src/pyper/_core/async_helper/output.py

@@ -6,7 +6,7 @@
 from typing import TYPE_CHECKING
 
 from .stage import AsyncProducer, AsyncProducerConsumer
-from ..util.asynchronize import ascynchronize
+from ..util.asynchronize import asynchronize
 from ..util.sentinel import StopSentinel
 
 if sys.version_info < (3, 11):  # pragma: no cover
@@ -26,7 +26,7 @@ def _get_q_out(self, tg: TaskGroup, tp: ThreadPoolExecutor, pp: ProcessPoolExecu
         """Feed forward each stage to the next, returning the output queue of the final stage."""
         q_out = None
         for task, next_task in zip(self.pipeline.tasks, self.pipeline.tasks[1:] + [None]):
-            task = ascynchronize(task, tp=tp, pp=pp)
+            task = asynchronize(task, tp=tp, pp=pp)
             if q_out is None:
                 stage = AsyncProducer(task=task, next_task=next_task)
                 stage.start(tg, *args, **kwargs)

src/pyper/_core/util/asynchronize.py

@@ -7,7 +7,7 @@
 from ..task import Task
 
 
-def ascynchronize(task: Task, tp: ThreadPoolExecutor, pp: ProcessPoolExecutor) -> Task:
+def asynchronize(task: Task, tp: ThreadPoolExecutor, pp: ProcessPoolExecutor) -> Task:
     """Unify async and sync tasks as awaitable futures.
     1. If the task is async already, return it.
     2. Multiprocessed synchronous functions are wrapped in a call to `run_in_executor` using `ProcessPoolExecutor`.
@@ -36,3 +36,7 @@ async def wrapper(*args, **kwargs):
         workers=task.workers,
         throttle=task.throttle
     )
+
+
+# backwards compatibility
+ascynchronize = asynchronize