Function unsafeEjectStreamScope

packages/platform/src/HttpApp.ts:145–162

(
  response: ServerResponse.HttpServerResponse
)

 * @category Scope
 */
export const unsafeEjectStreamScope = (
  response: ServerResponse.HttpServerResponse
): ServerResponse.HttpServerResponse => {
  if (response.body._tag !== "Stream") {
    return response
  }
  const fiber = Option.getOrThrow(Fiber.getCurrentFiber())
  const scope = Context.unsafeGet(fiber.currentContext, Scope.Scope) as Scope.CloseableScope
  ejectDefaultScopeClose(scope)
  return ServerResponse.setBody(
    response,
    HttpBody.stream(
      Stream.ensuring(response.body.stream, Scope.close(scope, Exit.void)),
      response.body.contentType,
      response.body.contentLength
    )
  )
}

const ejectedScopes = GlobalValue.globalValue(
  "@effect/platform/HttpApp/ejectedScopes",