Skip to content

Commit a3e62b7

Browse files
committed
fixed unbuffered channel style
1 parent e944e27 commit a3e62b7

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

lib/concurrent/channel/unbuffered_channel.rb

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,12 +35,12 @@ def remove_probe(probe)
3535
end
3636

3737
private
38-
def first_waiting_probe
39-
@mutex.synchronize do
40-
@condition.wait(@mutex) while @probe_set.empty?
41-
@probe_set.shift
42-
end
38+
def first_waiting_probe
39+
@mutex.synchronize do
40+
@condition.wait(@mutex) while @probe_set.empty?
41+
@probe_set.shift
4342
end
43+
end
4444

4545
end
4646
end

0 commit comments

Comments
 (0)