Function readResponseBody

packages/plugins/openapi/src/sdk/invoke.ts:1247–1291

(body: Effect.Effect<A, OpenApiInvocationError, never>)

      }),
  );
  const readResponseBody = <A>(body: Effect.Effect<A, OpenApiInvocationError, never>) =>
    Effect.gen(function* () {
      const bodyExitOption = yield* Effect.callback<
        Option.Option<Exit.Exit<A, OpenApiInvocationError>>
      >((resume, signal) => {
        let settled = false;
        const bodyEffect = body.pipe(
          Effect.exit,
          Effect.tap((exit) =>
            Effect.sync(() => {
              if (settled) return;
              settled = true;
              clearTimeout(timer);
              resume(Effect.succeed(Option.some(exit)));
            }),
          ),
        );
        const fiber = runFork(bodyEffect);
        const interrupt = () => {
          runFork(Fiber.interrupt(fiber));
        };
        const timer = setTimeout(() => {
          if (settled) return;
          settled = true;
          interrupt();
          resume(Effect.succeed(Option.none()));
        }, responseBodyTimeoutMs);
        signal.addEventListener("abort", interrupt, { once: true });
        return Effect.sync(() => {
          clearTimeout(timer);
          signal.removeEventListener("abort", interrupt);
          if (!settled) interrupt();
        });
      });
      if (Option.isNone(bodyExitOption)) {
        return yield* new OpenApiInvocationError({
          message: responseBodyTimeoutMessage(responseBodyTimeoutMs),
          statusCode: Option.some(status),
          reason: "response_body_timeout",
        });
      }
      const bodyExit = bodyExitOption.value;
      if (Exit.isFailure(bodyExit)) return yield* Effect.failCause(bodyExit.cause);
      return bodyExit.value;
    });
  const responseBodyBinding = Option.getOrUndefined(operation.responseBody);
  const fileHint = responseBodyBinding
    ? Option.getOrUndefined(responseBodyBinding.fileHint)