ZIO<R, E, A>.async constructor

ZIO<R, E, A>.async(
  1. void f(
    1. AsyncContext<E, A> resume
    )
)

Implementation

factory ZIO.async(void Function(AsyncContext<E, A> resume) f) =>
    ZIO.from((ctx) {
      final context = AsyncContext<E, A>();
      f(context);
      return context._deferred.await().unsafeRun(ctx);
    });