Skip to content

Commit

Permalink
remove test for unsupported async write
Browse files Browse the repository at this point in the history
  • Loading branch information
tagomoris committed Nov 1, 2016
1 parent 1b6f297 commit fd8d86f
Showing 1 changed file with 0 additions and 29 deletions.
29 changes: 0 additions & 29 deletions test/plugin/test_out_stdout.rb
Original file line number Diff line number Diff line change
Expand Up @@ -139,21 +139,6 @@ def create_driver(conf = CONFIG)
end
assert_equal "#{Time.at(time).localtime.strftime(TIME_FORMAT)} test: {\"test\":\"test\"}\n", out
end

data('oj' => 'oj', 'yajl' => 'yajl')
test '#try_write(asynchronous)' do |data|
d = create_driver(config_element("ROOT", "", {"output_type" => "json", "json_parser" => data}, [config_element("buffer")]))
time = event_time()
d.instance.delayed = true

out = capture_log do
d.run(default_tag: 'test', flush: true, shutdown: false) do
d.feed(time, {'test' => 'test'})
end
end

assert_equal "#{Time.at(time).localtime.strftime(TIME_FORMAT)} test: {\"test\":\"test\"}\n", out
end
end

sub_test_case 'emit hash' do
Expand All @@ -169,20 +154,6 @@ def create_driver(conf = CONFIG)

assert_equal "#{Time.at(time).localtime.strftime(TIME_FORMAT)} test: {\"test\"=>\"test\"}\n", out
end

test '#try_write(asynchronous)' do
d = create_driver(config_element("ROOT", "", {"output_type" => "hash"}, [config_element("buffer")]))
time = event_time()
d.instance.delayed = true

out = capture_log do
d.run(default_tag: 'test', flush: true, shutdown: false) do
d.feed(time, {'test' => 'test'})
end
end

assert_equal "#{Time.at(time).localtime.strftime(TIME_FORMAT)} test: {\"test\"=>\"test\"}\n", out
end
end
end

Expand Down

0 comments on commit fd8d86f

Please sign in to comment.