tests.test_utils_run.test_run_curio()

Complexity

Conditions

3

Size

Total Lines	17
Code Lines	14

Duplication

Lines	17
Ratio	100 %

Importance

Changes

0

from contextvars import ContextVar
def test_run_curio():

This code seems to be duplicated in your project.

    counter = ContextVar("counter", default=5)

    async def reset_counter():
        if counter.get() == 5:
            counter.set(0)
            return 0
        return -1

    with Kernel() as kernel:
        assert run(kernel, reset_counter) == 0
        assert run(kernel, reset_counter) == 0
        assert counter.get() == 5

    assert _curio_run(reset_counter) == 0
    assert _curio_run(reset_counter) == -1
    assert counter.get() == 0