spec/inputs/tcp_spec.rb in logstash-input-tcp-2.0.2 vs spec/inputs/tcp_spec.rb in logstash-input-tcp-2.0.3

@@ -224,10 +224,11 @@
       srand(RSpec.configuration.seed)
     end
 
     let(:port) { rand(1024..65535) }
     subject { LogStash::Plugin.lookup("input", "tcp").new({ "port" => port }) }
+    let!(:helper) { TcpHelpers.new }
 
     after :each do
       subject.close rescue nil
     end
 
@@ -242,10 +243,10 @@
       let(:nevents) { 10 }
 
       let(:events) do
         socket = Stud::try(5.times) { TCPSocket.new("127.0.0.1", port) }
 
-        result = pipelineless_input(subject, nevents) do
+        result = helper.pipelineless_input(subject, nevents) do
           nevents.times do |i|
             socket.puts("msg #{i}")
             socket.flush
           end
         end