Function sendInterrupt

packages/rpc/src/RpcClient.ts:519–542

(
    requestId: RequestId,
    interruptors: ReadonlyArray<FiberId.FiberId>,
    context: Context.Context<never>
  )

  }

  const sendInterrupt = (
    requestId: RequestId,
    interruptors: ReadonlyArray<FiberId.FiberId>,
    context: Context.Context<never>
  ): Effect.Effect<void> =>
    Effect.async<void>((resume) => {
      const parentFiber = Option.getOrThrow(Fiber.getCurrentFiber())
      const runtime = Runtime.make({
        context: parentFiber.currentContext,
        fiberRefs: parentFiber.getFiberRefs(),
        runtimeFlags: Runtime.defaultRuntime.runtimeFlags
      })
      const fiber = options.onFromClient({
        message: { _tag: "Interrupt", requestId, interruptors },
        context,
        discard: false
      }).pipe(
        Effect.timeout(1000),
        Runtime.runFork(runtime)
      )
      fiber.addObserver(() => {
        resume(Effect.void)
      })
    })

  const write = (message: FromServer<Rpcs>): Effect.Effect<void> => {
    switch (message._tag) {