Function streamRequest

packages/ai/anthropic/src/AnthropicClient.ts:227–259

(
    request: HttpClientRequest.HttpClientRequest,
    schema: Schema.Schema<A, I, R>
  )

  })

  const streamRequest = <A, I, R>(
    request: HttpClientRequest.HttpClientRequest,
    schema: Schema.Schema<A, I, R>
  ): Stream.Stream<A, AiError.AiError, R> => {
    const decodeEvents = Schema.decode(Schema.ChunkFromSelf(Schema.parseJson(schema)))
    return httpClientOk.execute(request).pipe(
      Effect.map((r) => r.stream),
      Stream.unwrapScoped,
      Stream.decodeText(),
      Stream.pipeThroughChannel(Sse.makeChannel()),
      Stream.mapChunksEffect((chunk) => decodeEvents(Chunk.map(chunk, (event) => event.data))),
      Stream.catchTags({
        RequestError: (error) =>
          AiError.HttpRequestError.fromRequestError({
            module: "AnthropicClient",
            method: "streamRequest",
            error
          }),
        ResponseError: (error) =>
          AiError.HttpResponseError.fromResponseError({
            module: "AnthropicClient",
            method: "streamRequest",
            error
          }),
        ParseError: (error) =>
          AiError.MalformedOutput.fromParseError({
            module: "AnthropicClient",
            method: "streamRequest",
            error
          })
      })
    )
  }

  const createMessage: (options: {
    readonly params?: typeof Generated.BetaMessagesPostParams.Encoded | undefined