Function streamToResponse

packages/effect/src/unstable/httpapi/HttpApiClient.ts:865–890

(successSchema: StreamSuccessSchema)

}

function streamToResponse(successSchema: StreamSuccessSchema) {
  const isWithHeaders = isWithHeadersStreamSuccess(successSchema)
  const streamSchema = isWithHeaders ? successSchema.schema : successSchema
  const sse = HttpApiSchema.isStreamUint8Array(streamSchema)
    ? undefined
    : {
      declaration: streamSchema,
      decoder: makeSseDecoder(streamSchema)
    }
  const toStream = (response: HttpClientResponse.HttpClientResponse) =>
    Effect.map(Effect.context<never>(), (context) =>
      Stream.provideContext(
        sse === undefined ?
          response.stream :
          decodeSseStream(response.stream, sse.declaration, sse.decoder),
        context as Context.Context<unknown>
      ))
  if (!isWithHeaders) return toStream

  const decodeHeaders = Schema.decodeUnknownEffect(successSchema.headers)
  return (response: HttpClientResponse.HttpClientResponse) =>
    Effect.flatMap(
      decodeHeaders(response.headers),
      (headers) => Effect.map(toStream(response), (body) => HttpApiSchema.withHeaders({ body, headers }))
    )
}

function makeSseDecoder(
  declaration: HttpApiSchema.StreamSse<Sse.EventCodec, Schema.Constraint, unknown>