Skip to content

Commit 29b8ef3

Browse files
committed
Fix blocking: true and add spec.
1 parent 4df9571 commit 29b8ef3

File tree

2 files changed

+14
-1
lines changed

2 files changed

+14
-1
lines changed

lib/async/container/generic.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ def delete(key, child)
273273

274274
private
275275

276-
if Fiber.respond_to?(:blocking)
276+
if Fiber.respond_to?(:blocking?)
277277
def fiber(&block)
278278
Fiber.new(blocking: true, &block)
279279
end

spec/async/container/shared_examples.rb

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,19 @@
4848
subject.wait
4949
end
5050

51+
it "should be blocking", if: Fiber.respond_to?(:blocking?) do
52+
input, output = IO.pipe
53+
54+
subject.spawn do
55+
output.write(Fiber.blocking? != false)
56+
end
57+
58+
subject.wait
59+
60+
output.close
61+
expect(input.read).to be == "true"
62+
end
63+
5164
describe '#sleep' do
5265
it "can sleep for a short time" do
5366
subject.spawn do

0 commit comments

Comments
 (0)