FiberMapAsyncRuntime

__init__(run) -> None

def __init__(self, run: FiberMapRuntime[K, A, E, R]) -> None:
    self._run = run

__call__(key, eff, /, *, only_if_missing=False, propagate_interruption=False, uninterruptible=False, scheduler=None) -> asyncio.Future[A]

def __call__(
    self,
    key: K,
    eff: Effect[A, E, R],
    /,
    *,
    only_if_missing: bool = False,
    propagate_interruption: bool = False,
    uninterruptible: bool = False,
    scheduler: Scheduler | None = None,
) -> asyncio.Future[A]:
    require_effect(eff, "eff")
    return future_of(
        self._run(
            key,
            eff,
            only_if_missing=only_if_missing,
            propagate_interruption=propagate_interruption,
            uninterruptible=uninterruptible,
            scheduler=scheduler,
        )
    )