soulfire.transport

Functions

rpc(→ effect_py.Effect[A, ...)
validate(→ effect_py.Effect[A, ...)
rpc_stream(→ soulfire.streams.Stream[A, ...)

Module Contents

soulfire.transport.rpc[A](operation: str, call: collections.abc.Callable[[], collections.abc.Awaitable[A]]) → effect_py.Effect[A, soulfire.errors.SoulFireRpcError]

soulfire.transport.validate[A](call: collections.abc.Callable[[], A]) → effect_py.Effect[A, soulfire.errors.SoulFireOperationError]

soulfire.transport.rpc_stream[A](operation: str, factory: collections.abc.Callable[[], collections.abc.AsyncIterator[A]]) → soulfire.streams.Stream[A, soulfire.errors.SoulFireOperationError]