Return sized enumerator from Batches#find_each

activerecord/CHANGELOG.md

@@ -1,4 +1,10 @@
-*   `find_in_batches` now returns an `Enumerator` that can calculate its size.
+<<<<<<< HEAD
+*   `find_in_batches`, `find_each` now
+    return an `Enumerator` that can calculate its size.
+=======
+*   `find_in_batches`, `find_each`, `Result#each` now returns an `Enumerator`
+    that can calculate its size.
+>>>>>>> 5863938... Return sized enumerator from Result#each
 
     See also #13938.
 

activerecord/lib/active_record/relation/batches.rb

@@ -52,7 +52,9 @@ def find_each(options = {})
           records.each { |record| yield record }
         end
       else
-        enum_for :find_each, options
+        enum_for :find_each, options do
+          options[:start] ? where(table[primary_key].gteq(options[:start])).size : size
+        end
       end
     end
 

activerecord/lib/active_record/result.rb

@@ -54,7 +54,7 @@ def each
       if block_given?
         hash_rows.each { |row| yield row }
       else
-        hash_rows.to_enum
+        hash_rows.to_enum { @rows.size }
       end
     end
 

activerecord/test/cases/batches_test.rb

@@ -35,6 +35,14 @@ def test_each_should_return_an_enumerator_if_no_block_is_present
     end
   end
 
+  if Enumerator.method_defined? :size
+    def test_each_should_return_a_sized_enumerator
+      assert_equal 11, Post.find_each(:batch_size => 1).size
+      assert_equal 5, Post.find_each(:batch_size => 2, :start => 7).size
+      assert_equal 11, Post.find_each(:batch_size => 10_000).size
+    end
+  end
+
   def test_each_enumerator_should_execute_one_query_per_batch
     assert_queries(@total + 1) do
       Post.find_each(:batch_size => 1).with_index do |post, index|

activerecord/test/cases/result_test.rb

@@ -30,5 +30,11 @@ def test_each_without_block_returns_an_enumerator
         assert_kind_of Integer, index
       end
     end
+
+    if Enumerator.method_defined? :size
+      def test_each_without_block_returns_a_sized_enumerator
+        assert_equal 3, result.each.size
+      end
+    end
   end
 end

activesupport/lib/active_support/core_ext/enumerable.rb

@@ -35,7 +35,7 @@ def index_by
     if block_given?
       Hash[map { |elem| [yield(elem), elem] }]
     else
-      to_enum :index_by
+      to_enum(:index_by) { size }
     end
   end