diff --git a/spec/inputs/tcp.rb b/spec/inputs/tcp.rb
index 798a00bda..338502acc 100644
--- a/spec/inputs/tcp.rb
+++ b/spec/inputs/tcp.rb
@@ -76,7 +76,7 @@ describe "inputs/tcp" do
       output = Shiftback.new do |event|
         sequence += 1
         begin
-          insist { event.message } == "Hello ü Û"
+          insist { event.message } == "Hello ü Û\n"
           insist { event.message.encoding } == Encoding.find("UTF-8")
         rescue Exception => failure
           # Get out of the threads nets
@@ -93,13 +93,11 @@ describe "inputs/tcp" do
         tcp.run(output)
       end
       #Send events from clients sockets
+      client_socket = TCPSocket.new("0.0.0.0", port)
       event_count.times do |value|
-        client_socket = TCPSocket.new("0.0.0.0", port)
-        client_socket.write "Hello ü Û"
-        client_socket.close
-        # micro sleep to ensure sequencing
-        sleep(0.1)
+        client_socket.write "Hello ü Û\n"
       end
+      client_socket.close
       #wait for input termination
       puts "Waiting for tcp input thread to finish"
       thread.join