diff --git a/lib/rackstash/flows.rb b/lib/rackstash/flows.rb
index 1195011..f3c95a7 100644
--- a/lib/rackstash/flows.rb
+++ b/lib/rackstash/flows.rb
@@ -61,17 +61,18 @@ module Rackstash
     # a parameter. We only yield non-nil elements. Concurrent changes to `self`
     # do not affect the running enumeration.
     #
-    # An Enumerator is returned if no block is given.
+    # An `Enumerator` is returned if no block is given.
     #
     # @yield [flow] calls the given block once for each flow
     # @yieldparam flow [Flow] the yielded flow
-    # @return [Enumerator, Array<Flow>] Returns an array of the flows if a
-    #   block was given or an `Enumerator` if no block was given.
+    # @return [Enumerator, self] `self` if a block was given or an `Enumerator`
+    #   if no block was given.
     def each
       return enum_for(__method__) unless block_given?
       to_a.each do |flow|
         yield flow
       end
+      self
     end
 
     # @return [Boolean] `true` if `self` contains no elements, `false` otherwise
diff --git a/spec/rackstash/flows_spec.rb b/spec/rackstash/flows_spec.rb
index cdcd153..ad4fecf 100644
--- a/spec/rackstash/flows_spec.rb
+++ b/spec/rackstash/flows_spec.rb
@@ -128,9 +128,9 @@ describe Rackstash::Flows do
       expect { |b| flows.each(&b) }.to yield_control.once
     end
 
-    it 'returns an array if a block was provided' do
+    it 'returns the flow if a block was provided' do
       flows << a_flow
-      expect(flows.each {}).to be_instance_of Array
+      expect(flows.each {}).to equal flows
     end
 
     it 'returns an Enumerator if no block was provided' do