spec/spec_helper.rb in logstash-input-tcp-2.0.2 vs spec/spec_helper.rb in logstash-input-tcp-2.0.3
- old
+ new
@@ -1,27 +1,22 @@
# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
# this has been taken from the udp input, it should be DRYed
-module TcpHelpers
+class TcpHelpers
def pipelineless_input(plugin, size, &block)
queue = Queue.new
input_thread = Thread.new do
plugin.run(queue)
end
block.call
sleep 0.1 while queue.size != size
- result = nevents.times.inject([]) do |acc|
+ result = size.times.inject([]) do |acc|
acc << queue.pop
end
plugin.do_stop
input_thread.join
result
end
-
-end
-
-RSpec.configure do |c|
- c.include TcpHelpers
end