make input plugin instance sure to listen

fluent · Aug 4, 2016 · f0a01fb · f0a01fb
1 parent 0d5dd22
commit f0a01fb
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/test/plugin/test_out_forward.rb b/test/plugin/test_out_forward.rb
@@ -420,6 +420,8 @@ def test_authentication_with_shared_key
     ]
 
     target_input_driver.run do
+      sleep 0.1 until target_input_driver.instance.instance_eval{ @thread } && target_input_driver.instance.instance_eval{ @thread }.status
+
       d.run do
         records.each do |record|
           d.emit(record, time)
@@ -434,6 +436,7 @@ def test_authentication_with_shared_key
     end
 
     emits = target_input_driver.emits
+    assert{ emits != [] }
     assert_equal(['test', time, records[0]], emits[0])
     assert_equal(['test', time, records[1]], emits[1])
   end
@@ -480,6 +483,8 @@ def test_authentication_with_user_auth
     ]
 
     target_input_driver.run do
+      sleep 0.1 until target_input_driver.instance.instance_eval{ @thread } && target_input_driver.instance.instance_eval{ @thread }.status
+
       d.run do
         records.each do |record|
           d.emit(record, time)
@@ -494,6 +499,7 @@ def test_authentication_with_user_auth
     end
 
     emits = target_input_driver.emits
+    assert{ emits != [] }
     assert_equal(['test', time, records[0]], emits[0])
     assert_equal(['test', time, records[1]], emits[1])
   end