Function toStream

packages/effect/src/unstable/httpapi/HttpApiClient.ts:874–881

(response: HttpClientResponse.HttpClientResponse)

      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)