Module: AsyncObserver::Extensions

Defined in:
lib/async_observer/queue.rb,
lib/async_observer/extend.rb

Instance Method Summary collapse

Instance Method Details

#async_send(selector, *args) ⇒ Object 



32
33
34
 
# File 'lib/async_observer/extend.rb', line 32

def async_send(selector, *args)
  async_send_opts(selector, {}, *args)
end

#async_send_opts(selector, opts, *args) ⇒ Object 



36
37
38
 
# File 'lib/async_observer/extend.rb', line 36

def async_send_opts(selector, opts, *args)
  AsyncObserver::Queue.put_call!(self, selector, opts, args)
end

#rrepr ⇒ Object 



174
175
176
177
 
# File 'lib/async_observer/queue.rb', line 174

def rrepr()
  method = (respond_to? :get_cache) ? 'get_cache' : 'find'
  "#{self.class.rrepr}.#{method}(#{id.rrepr})"
end