Skip to content

Commit e4e4bcf

Browse files
committed
wait for Consumer to consume the poison object
1 parent c429483 commit e4e4bcf

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

test/consumer_test.rb

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -133,6 +133,8 @@ def run
133133
c = Consumer.new(q, 1)
134134
t = Thread.new { c.consume }
135135

136+
Timeout.timeout(1) { sleep(0.1) while t.status }
137+
136138
assert_equal 1, q.length
137139
assert_equal 0, Actionable.ran.length
138140
end

0 commit comments

Comments
 (0)