diff --git a/tests/test_docs_examples.py b/tests/test_docs_examples.py index 5f47419..af17ff1 100644 --- a/tests/test_docs_examples.py +++ b/tests/test_docs_examples.py @@ -1,6 +1,7 @@ -""" +''' Let's make sure them docs work yah? -""" + +''' from contextlib import contextmanager import itertools import os diff --git a/tests/test_infected_asyncio.py b/tests/test_infected_asyncio.py index def1776..2beac71 100644 --- a/tests/test_infected_asyncio.py +++ b/tests/test_infected_asyncio.py @@ -1,8 +1,13 @@ +''' +The most hipster way to force SC onto the stdlib's "async". + +''' import asyncio import pytest import tractor + async def sleep_and_err(): await asyncio.sleep(0.1) assert 0 @@ -14,7 +19,7 @@ async def asyncio_actor(): await tractor.to_asyncio.run_task(sleep_and_err) -def test_infected_simple_error(arb_addr): +def test_aio_simple_error(arb_addr): async def main(): async with tractor.open_nursery() as n: @@ -22,3 +27,35 @@ def test_infected_simple_error(arb_addr): with pytest.raises(tractor.RemoteActorError) as excinfo: tractor.run(main, arbiter_addr=arb_addr) + + +def test_aio_cancel_from_trio(arb_addr): + ... + + +def test_aio_cancelled_from_aio_causes_trio_cancelled(arb_addr): + ... + + +def test_trio_cancels_aio(arb_addr): + ... + + +def test_trio_error_cancels_aio(arb_addr): + ... + + +def test_basic_interloop_channel_stream(arb_addr): + ... + + +def test_basic_interloop_channel_stream(arb_addr): + ... + + +def test_trio_cancels_and_channel_exits(arb_addr): + ... + + +def test_aio_errors_and_channel_propagates(arb_addr): + ...