MCPcopy Create free account
hub / github.com/Effect-TS/effect / fiberInterruptAll

Function fiberInterruptAll

packages/effect/src/internal/effect.ts:887–898  ·  view source on GitHub ↗
(
  fibers: A
)

Source from the content-addressed store, hash-verified

885
886/** @internal */
887export const fiberInterruptAll = <A extends Iterable<Fiber.Fiber<any, any>>>(
888 fibers: A
889): Effect.Effect<void> =>
890 withFiber((parent) => {
891 const annotations = fiberStackAnnotations(parent)
892 let fiberArr = Arr.empty<Fiber.Fiber<any, any>>()
893 for (const fiber of fibers) {
894 fiber.interruptUnsafe(parent.id, annotations)
895 fiberArr.push(fiber)
896 }
897 return asVoid(fiberAwaitAll(fiberArr))
898 })
899
900/** @internal */
901export const fiberInterruptAllAs: {

Callers 6

fiberInterruptChildrenFunction · 0.85
onExitFunction · 0.85
raceAllFunction · 0.85
raceAllFirstFunction · 0.85
failDefectFunction · 0.85
goFunction · 0.85

Calls 5

fiberStackAnnotationsFunction · 0.85
asVoidFunction · 0.85
fiberAwaitAllFunction · 0.85
interruptUnsafeMethod · 0.80
pushMethod · 0.80

Tested by

no test coverage detected