Continuation queue implementation for MRI and Rubinius
@private
# File lib/bunny/concurrent/continuation_queue.rb, line 32 def clear @q.clear end
# File lib/bunny/concurrent/continuation_queue.rb, line 36 def method_missing(selector, *args, &block) @q.__send__(selector, *args, &block) end
# File lib/bunny/concurrent/continuation_queue.rb, line 22 def poll(timeout_in_ms = nil) if timeout_in_ms Bunny::Timeout.timeout(timeout_in_ms / 1000, ::Timeout::Error) do @q.pop end else @q.pop end end
# File lib/bunny/concurrent/continuation_queue.rb, line 18 def pop @q.pop end
# File lib/bunny/concurrent/continuation_queue.rb, line 13 def push(*args) @q.push(*args) end
Generated with the Darkfish Rdoc Generator 2.