Skip to content

Commit b28d777

Browse files
committed
Rename Async::LimitedBarrier to Async::Waiter.
1 parent 375bf9b commit b28d777

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

lib/async/limited_barrier.rb renamed to lib/async/waiter.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55

66
module Async
77
# A composable synchronization primitive, which allows one task to wait for a number of other tasks to complete. It can be used in conjunction with {Semaphore} and/or {Barrier}.
8-
class LimitedBarrier
8+
class Waiter
99
def initialize(parent: nil, finished: Async::Condition.new)
1010
@finished = finished
1111
@done = []
Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,23 +1,23 @@
11

2-
require 'async/limited_barrier'
2+
require 'async/waiter'
33
require 'sus/fixtures/async'
44

5-
describe Async::LimitedBarrier do
5+
describe Async::Waiter do
66
include Sus::Fixtures::Async::ReactorContext
77

8-
let(:limited_barrier) {subject.new}
8+
let(:waiter) {subject.new}
99

1010
it "can wait for a subset of tasks" do
1111
3.times do
12-
limited_barrier.async do
12+
waiter.async do
1313
sleep(rand * 0.01)
1414
end
1515
end
1616

17-
done = limited_barrier.wait(2)
17+
done = waiter.wait(2)
1818
expect(done.size).to be == 2
1919

20-
done = limited_barrier.wait(1)
20+
done = waiter.wait(1)
2121
expect(done.size).to be == 1
2222
end
2323
end

0 commit comments

Comments
 (0)