module RubyLLM::Providers::Bedrock::Streaming::MessageProcessing

def process_valid_message(chunk, offset, message_info, &)
  payload = extract_payload(chunk, message_info[:headers_end], message_info[:payload_end])
  return find_next_message(chunk, offset) unless valid_payload?(payload)
  process_payload(payload, &)
  offset + message_info[:total_length]
end