mirror of
https://github.com/promplate/pyth-on-line.git
synced 2025-09-04 17:53:00 +00:00
chore: rename create_task_factory
to create_trio_task_factory
for clarity
This commit is contained in:
@@ -4,7 +4,7 @@ from functools import partial, wraps
|
||||
from pytest import raises
|
||||
from reactivity.async_primitives import AsyncDerived, AsyncEffect
|
||||
from reactivity.primitives import Derived, Signal
|
||||
from utils import Clock, capture_stdout, create_task_factory, run_trio_in_asyncio
|
||||
from utils import Clock, capture_stdout, create_trio_task_factory, run_trio_in_asyncio
|
||||
|
||||
|
||||
def trio(func):
|
||||
@@ -138,7 +138,7 @@ async def test_trio_nested_derived():
|
||||
from trio.testing import wait_all_tasks_blocked
|
||||
|
||||
async with open_nursery() as nursery:
|
||||
factory = create_task_factory(nursery)
|
||||
factory = create_trio_task_factory(nursery)
|
||||
|
||||
s = Signal(0)
|
||||
|
||||
|
@@ -1,6 +1,6 @@
|
||||
from .io import capture_stdout
|
||||
from .time import Clock
|
||||
from .tmpenv import environment
|
||||
from .trio import create_task_factory, run_trio_in_asyncio
|
||||
from .trio import create_trio_task_factory, run_trio_in_asyncio
|
||||
|
||||
__all__ = "Clock", "capture_stdout", "create_task_factory", "environment", "run_trio_in_asyncio"
|
||||
__all__ = "Clock", "capture_stdout", "create_trio_task_factory", "environment", "run_trio_in_asyncio"
|
||||
|
@@ -39,7 +39,7 @@ async def run_trio_in_asyncio[T](trio_main: Callable[[], Coroutine[Any, Any, T]]
|
||||
return await future
|
||||
|
||||
|
||||
def create_task_factory(nursery: "Nursery"):
|
||||
def create_trio_task_factory(nursery: "Nursery"):
|
||||
from trio import Event
|
||||
|
||||
def task_factory[T](async_fn: AsyncFunction[T]) -> Awaitable[T]:
|
||||
|
Reference in New Issue
Block a user