Function finalizersMaskInternal

packages/effect/src/internal/fiberRuntime.ts:2826–2855

(strategy: ExecutionStrategy.ExecutionStrategy, concurrentFinalizers?: boolean | undefined)

/* @internal */
export const finalizersMaskInternal =
  (strategy: ExecutionStrategy.ExecutionStrategy, concurrentFinalizers?: boolean | undefined) =>
  <A, E, R>(
    self: (
      restore: <A1, E1, R1>(self: Effect.Effect<A1, E1, R1>) => Effect.Effect<A1, E1, R1>
    ) => Effect.Effect<A, E, R>
  ): Effect.Effect<A, E, R> =>
    core.contextWithEffect((context) =>
      Option.match(Context.getOption(context, scopeTag), {
        onNone: () => self(identity),
        onSome: (scope) => {
          if (concurrentFinalizers === true) {
            const patch = strategy._tag === "Parallel"
              ? parallelFinalizers
              : strategy._tag === "Sequential"
              ? sequentialFinalizers
              : parallelNFinalizers(strategy.parallelism)
            switch (scope.strategy._tag) {
              case "Parallel":
                return patch(self(parallelFinalizers))
              case "Sequential":
                return patch(self(sequentialFinalizers))
              case "ParallelN":
                return patch(self(parallelNFinalizers(scope.strategy.parallelism)))
            }
          } else {
            return self(identity)
          }
        }
      })
    )

/* @internal */
export const scopeWith = <A, E, R>(