Object
@api Channel @!macro edge_warning
# File lib/concurrent/channel/buffered_channel.rb, line 22 def buffer_queue_size @mutex.synchronize { @buffer.count } end
# File lib/concurrent/channel/buffered_channel.rb, line 31 def pop probe = Channel::Probe.new select(probe) probe.value end
# File lib/concurrent/channel/buffered_channel.rb, line 18 def probe_set_size @probe_set.size end
# File lib/concurrent/channel/buffered_channel.rb, line 26 def push(value) until set_probe_or_push_into_buffer(value) end end
Generated with the Darkfish Rdoc Generator 2.