def bulk_stream_responses(ops, params = {})
      bulk_obj = Bulk.new(self, params)

      Enumerator.new do |yielder|
        ops.each do |action, *args|
          response = bulk_obj.send(action, *args)
          yielder.yield response unless response.nil?
        end

        response = bulk_obj.call
        yielder.yield response unless response.nil?
      end
    end
def bulk_stream_responses(ops, params = {})
      bulk_obj = Bulk.new(self, params)

      Enumerator.new do |yielder|
        ops.each do |action, *args|
          response = bulk_obj.send(action, *args)
          yielder.yield response unless response.nil?
        end

        response = bulk_obj.call
        yielder.yield response unless response.nil?
      end
    end
Stream bulk actions from an Enumerator.

 Examples

   ops = [
     [:index, document1, {:_type => "foo", :_id => 1}],
     [:create, document2],
     [:delete, {:_type => "bar", :_id => 42}]
   ]
   bulk_stream_responses(ops, :index => 'default-index').each do |response|
     puts response
   end

 Returns an Enumerator of responses.