fcheung/gist:92d77b62eb570031823d Secret

## gistfile1.rb

module Tire
  module Search
    class Search
      attr_reader :types
    end

    class MultiSearch

      def initialize(searches, options ={})
        @searches = searches
        @options = options
      end

      def to_payload
        payload = @searches.each_with_object([]) do |search, result|
          result << {:index => search.indices, :types => search.types}.to_json
          result << search.to_json
        end
        payload << ""
        payload.join("\n")
      end

      def results
        @results  || (perform; @results)
      end

      def perform
        response = Configuration.client.post("#{Configuration.url}/_msearch", to_payload)
        json     = MultiJson.decode(response.body)

        @results = json['responses'].each_with_index.collect do |response_json, index|
          Results::Collection.new(response_json, @options.merge(@searches[index].options))
        end
      end
    end
  end
end

	module Tire
	module Search
	class Search
	attr_reader :types
	end

	class MultiSearch

	def initialize(searches, options ={})
	@searches = searches
	@options = options
	end

	def to_payload
	payload = @searches.each_with_object([]) do \|search, result\|
	result << {:index => search.indices, :types => search.types}.to_json
	result << search.to_json
	end
	payload << ""
	payload.join("\n")
	end

	def results
	@results \|\| (perform; @results)
	end

	def perform
	response = Configuration.client.post("#{Configuration.url}/_msearch", to_payload)
	json = MultiJson.decode(response.body)

	@results = json['responses'].each_with_index.collect do \|response_json, index\|
	Results::Collection.new(response_json, @options.merge(@searches[index].options))
	end
	end
	end
	end
	end