Function cancelResponseBody

packages/platform/deno/src/DenoHttpServer.ts:516–522

(body: HttpBody.HttpBody)

}

const cancelResponseBody = (body: HttpBody.HttpBody): Effect.Effect<void> => {
  const stream = (body as any).body
  if ((body._tag === "Raw" || body._tag === "Uint8Array") && stream instanceof ReadableStream) {
    return Effect.ignoreCause(Effect.promise(() => stream.cancel()))
  }
  return Effect.void
}

const emptyReadableStream = new ReadableStream<Uint8Array>({
  start(controller) {