stream_raw

in lib/anthropic/resources/beta/messages.rb [90:111]

• 21 lines of code
• 3 McCabe index (conditional complexity)

        def stream_raw(params)
          parsed, options = Anthropic::Models::Beta::MessageCreateParams.dump_request(params)
          unless parsed.fetch(:stream, true)
            message = "Please use `#create` for the non-streaming use case."
            raise ArgumentError.new(message)
          end
          parsed.store(:stream, true)
          header_params = {betas: "anthropic-beta"}
          @client.request(
            method: :post,
            path: "v1/messages?beta=true",
            headers: {
              "accept" => "text/event-stream",
              **parsed.slice(*header_params.keys)
            }.transform_keys(header_params),
            body: parsed.except(*header_params.keys),
            stream: Anthropic::Internal::Stream,
            model: Anthropic::Models::Beta::BetaRawMessageStreamEvent,
            options: options
          )
        end