Function stream

packages/platform/src/internal/httpServerResponse.ts:315–327

(
  body: Stream.Stream<Uint8Array, E>,
  options?: ServerResponse.Options | undefined
)

/** @internal */
export const stream = <E>(
  body: Stream.Stream<Uint8Array, E>,
  options?: ServerResponse.Options | undefined
): ServerResponse.HttpServerResponse => {
  const headers = options?.headers ? Headers.fromInput(options.headers) : Headers.empty
  return new ServerResponseImpl(
    options?.status ?? 200,
    options?.statusText,
    headers,
    options?.cookies ?? Cookies.empty,
    internalBody.stream(body, getContentType(options, headers), options?.contentLength)
  )
}

/** @internal */
export const getContentType = (