spec/inputs/ganglia_spec.rb in logstash-input-ganglia-2.0.2 vs spec/inputs/ganglia_spec.rb in logstash-input-ganglia-2.0.3

@@ -43,13 +43,12 @@
     end
 
     let(:client) { GangliaClient.new("0.0.0.0", port) }
 
     let(:events) do
-      input(conf, nevents) do
-        nevents.times do |value|
-          client.send(data)
-        end
+      input(conf) do |pipeline, queue|
+        nevents.times         { client.send(data) }
+        nevents.times.collect { queue.pop }
       end
     end
 
     let(:event) { events[0] }