class Punchblock::Component::ComponentNode

Attributes

event_queue[RW]

Public Class Methods

new(*args) click to toggle source
Calls superclass method
# File lib/rspec-rayo.rb, line 23
def initialize(*args)
  super
  @event_queue = Queue.new
  register_event_handler do |event|
    @event_queue << event
  end
end

Public Instance Methods

next_event(timeout = nil) click to toggle source
# File lib/rspec-rayo.rb, line 31
def next_event(timeout = nil)
  Timeout::timeout(timeout || $config['rayo_queue']['connection_timeout']) { event_queue.pop }
end