@@ -500,10 +500,18 @@ def create_driver(conf)
500500 d = create_driver ( conf )
501501 time = event_time ( '2011-01-02 13:14:15' )
502502
503- d . run ( default_tag : 'test' , expect_emits : 1 , timeout : 10 , start : true , shutdown : false ) { d . feed ( time , { "k1" => 0 } ) }
504- d . run ( default_tag : 'test' , expect_emits : 1 , timeout : 10 , start : false , shutdown : false ) { d . feed ( time , { "k1" => 1 } ) }
505- d . run ( default_tag : 'test' , expect_emits : 1 , timeout : 10 , start : false , shutdown : false ) { d . feed ( time , { "k1" => 2 } ) }
506- d . run ( default_tag : 'test' , expect_emits : 1 , timeout : 10 , start : false , shutdown : false ) { d . feed ( time , { "k1" => 3 } ) }
503+ d . run ( default_tag : 'test' , expect_emits : 4 ) do
504+ d . feed ( time , { "k1" => 0 } )
505+ d . flush
506+ sleep 0.5
507+ d . feed ( time , { "k1" => 1 } )
508+ d . flush
509+ sleep 0.5
510+ d . feed ( time , { "k1" => 2 } )
511+ d . flush
512+ sleep 0.5
513+ d . feed ( time , { "k1" => 3 } )
514+ end
507515
508516 assert_equal "2011-01-02 13:14:15\t test\t 0\n " , d . formatted [ 0 ]
509517 assert_equal "2011-01-02 13:14:15\t test\t 1\n " , d . formatted [ 1 ]
@@ -524,9 +532,6 @@ def create_driver(conf)
524532 assert_equal pid_list [ 1 ] , events [ 1 ] [ 2 ] [ 'child_pid' ]
525533 assert_equal pid_list [ 0 ] , events [ 2 ] [ 2 ] [ 'child_pid' ]
526534 assert_equal pid_list [ 1 ] , events [ 3 ] [ 2 ] [ 'child_pid' ]
527-
528- ensure
529- d . run ( start : false , shutdown : true )
530535 end
531536
532537 # child process exits per 3 lines
0 commit comments