Parent

Class/Module Index [+]

Quicksearch

Bunny::Concurrent::ContinuationQueue

Continuation queue implementation for MRI and Rubinius

@private

Public Class Methods

new(*args, &block) click to toggle source
# File lib/bunny/concurrent/continuation_queue.rb, line 9
def initialize(*args, &block)
  @q = ::Queue.new(*args)
end

Public Instance Methods

<<(*args) click to toggle source
Alias for: push
clear() click to toggle source
# File lib/bunny/concurrent/continuation_queue.rb, line 32
def clear
  @q.clear
end
method_missing(selector, *args, &block) click to toggle source
# File lib/bunny/concurrent/continuation_queue.rb, line 36
def method_missing(selector, *args, &block)
  @q.__send__(selector, *args, &block)
end
poll(timeout_in_ms = nil) click to toggle source
# File lib/bunny/concurrent/continuation_queue.rb, line 22
def poll(timeout_in_ms = nil)
  if timeout_in_ms
    Bunny::Timer.timeout(timeout_in_ms / 1000, Timeout::Error) do
      @q.pop
    end
  else
    @q.pop
  end
end
pop() click to toggle source
# File lib/bunny/concurrent/continuation_queue.rb, line 18
def pop
  @q.pop
end
push(*args) click to toggle source
# File lib/bunny/concurrent/continuation_queue.rb, line 13
def push(*args)
  @q.push(*args)
end
Also aliased as: <<

[Validate]

Generated with the Darkfish Rdoc Generator 2.