Function createMessageStream

packages/ai/anthropic/src/AnthropicClient.ts:301–314

(options: {
    readonly params?: typeof Generated.BetaMessagesPostParams.Encoded | undefined
    readonly payload: Omit<typeof Generated.BetaCreateMessageParams.Encoded, "stream">
  })

  )

  const createMessageStream = (options: {
    readonly params?: typeof Generated.BetaMessagesPostParams.Encoded | undefined
    readonly payload: Omit<typeof Generated.BetaCreateMessageParams.Encoded, "stream">
  }): Stream.Stream<MessageStreamEvent, AiError.AiError> => {
    const request = HttpClientRequest.post("/v1/messages", {
      headers: Headers.fromInput({
        "anthropic-beta": options.params?.["anthropic-beta"] ?? undefined
      }),
      body: HttpBody.unsafeJson({ ...options.payload, stream: true })
    })
    return streamRequest(request, MessageStreamEvent).pipe(
      Stream.takeUntil((event) => event.type === "message_stop")
    )
  }

  return AnthropicClient.of({
    client,