Open History to see the last commit
1import * as Context from "effect/Context";
2import * as Deferred from "effect/Deferred";
3import * as Effect from "effect/Effect";
4import type * as Fiber from "effect/Fiber";
5import type * as Scope from "effect/Scope";
6
7export class ServerActivation extends Context.Reference<Effect.Effect<void> | undefined>(
8 "t3/serverActivation",
9 { defaultValue: () => undefined },
10) {}
11
12export const forkParkedFiber = Effect.fn("serverActivation.forkParkedFiber")(function* <A, E, R>(
13 effect: Effect.Effect<A, E, R>,
14): Effect.fn.Return<Fiber.Fiber<A, E>, never, Scope.Scope | R> {
15 const activation = yield* ServerActivation;
16 if (activation === undefined) {
17 return yield* Effect.forkScoped(effect);
18 }
19 const parked = yield* Deferred.make<void>();
20 const fiber = yield* Effect.forkScoped(
21 Deferred.succeed(parked, undefined).pipe(Effect.andThen(activation), Effect.andThen(effect)),
22 );
23 yield* Deferred.await(parked);
24 return fiber;
25});
26
27export const forkParked = <A, E, R>(
28 effect: Effect.Effect<A, E, R>,
29): Effect.Effect<void, never, Scope.Scope | R> => forkParkedFiber(effect).pipe(Effect.asVoid);