suned / stateless Goto Github PK

from typing import NoReturn as Never

from stateless import Effect, Runtime, parallel, success
from stateless.parallel import Parallel, thread


def f() -> Effect[Never, ValueError, str]:
    return success("done")


task = reveal_type(thread(f)())
r: Runtime[Parallel] = Runtime()

r.run(parallel(task))  # Argument 1 to "parallel" has incompatible type "Task[NoReturn, ValueError, str]"; expected "Task[Parallel, ValueError, str]"

from typing import NoReturn as Never

from stateless import Effect, Runtime, parallel, success
from stateless.parallel import Parallel, thread


def f() -> Effect[Never, ValueError, str]:
    return success("done")


task = reveal_type(thread(f)())
r: Runtime[Parallel] = Runtime()
effect = parallel(task)  # use an intermediate variable

r.run(effect)  # type error is gone

from stateless import Runtime

r: Runtime[str | bytes] = Runtime().use('hello!')

from stateless import Depend


e: Depend[bytes, float]
r.run(e)