elemental_isolates library

Extensions

ZIOIsolateExt on ZIO<R, E, A>

Properties

zioIsolateRunnerLayer → Layer<Never, ZIOIsolateRunner>
final

Functions

spawnIsolate<I, E, O>(IsolateHandler<I, E, O> handle, Dequeue<Request<I, E, O>> requests) → ZIO<Scope<NoEnv>, IsolateError, Never>
spawnIsolatePool<I, E, O>(IsolateHandler<I, E, O> handle, {required Dequeue<Request<I, E, O>> requests, int? maxSize, Schedule<Scope<NoEnv>, IsolateError, IsolateError, dynamic>? respawnSchedule}) → ZIO<Scope<NoEnv>, IsolateError, Never>

Typedefs

IsolateHandler<I, E, O> = EIO<E, O> Function(I input)
Request<I, E, O> = (I, Deferred<E, O>)