class RubyLLM::MCP::Transports::StreamableHTTP

def setup_response_queue(request_id, wait_for_response)
  response_queue = Queue.new
  if wait_for_response && request_id
    @pending_mutex.synchronize do
      @pending_requests[request_id.to_s] = response_queue
    end
  end
  response_queue
end