spec/rdkafka/consumer_spec.rb in rdkafka-0.13.0.beta.5 vs spec/rdkafka/consumer_spec.rb in rdkafka-0.13.0.beta.6

@@ -935,15 +935,15 @@
     end
 
     context "with a working listener" do
       let(:listener) do
         Struct.new(:queue) do
-          def on_partitions_assigned(consumer, list)
+          def on_partitions_assigned(list)
             collect(:assign, list)
           end
 
-          def on_partitions_revoked(consumer, list)
+          def on_partitions_revoked(list)
             collect(:revoke, list)
           end
 
           def collect(name, list)
             partitions = list.to_h.map { |key, values| [key, values.map(&:partition)] }.flatten
@@ -963,16 +963,16 @@
     end
 
     context "with a broken listener" do
       let(:listener) do
         Struct.new(:queue) do
-          def on_partitions_assigned(consumer, list)
+          def on_partitions_assigned(list)
             queue << :assigned
             raise 'boom'
           end
 
-          def on_partitions_revoked(consumer, list)
+          def on_partitions_revoked(list)
             queue << :revoked
             raise 'boom'
           end
         end.new([])
       end
@@ -1035,14 +1035,14 @@
       config.consumer
     end
 
     let(:listener) do
       Struct.new(:queue) do
-        def on_partitions_assigned(consumer, list)
+        def on_partitions_assigned(list)
           collect(:assign, list)
         end
 
-        def on_partitions_revoked(consumer, list)
+        def on_partitions_revoked(list)
           collect(:revoke, list)
         end
 
         def collect(name, list)
           partitions = list.to_h.map { |key, values| [key, values.map(&:partition)] }.flatten