Object
@api Channel @!macro edge_warning
# File lib/concurrent/channel/unbuffered_channel.rb, line 23 def pop probe = Channel::Probe.new select(probe) probe.value end
# File lib/concurrent/channel/unbuffered_channel.rb, line 14 def probe_set_size @probe_set.size end
# File lib/concurrent/channel/unbuffered_channel.rb, line 18 def push(value) until @probe_set.take.try_set([value, self]) end end
Generated with the Darkfish Rdoc Generator 2.