class Newque::Util

Public Class Methods

compute_options(base_options, options) click to toggle source
# File lib/newque/util.rb, line 5
def self.compute_options base_options, options
  Hash[
    base_options.map do |name, default_value|
      [name, (options[name].nil? ? default_value : options[name])]
    end
  ]
end
newque_error(errors) click to toggle source
# File lib/newque/util.rb, line 17
def self.newque_error errors
  NewqueError.new "Client Error#{errors.size > 1 ? 's' : ''}: #{errors.join(', ')}"
end
resolve_t(thread, result) click to toggle source
# File lib/newque/util.rb, line 36
def self.resolve_t thread, result
  thread.thread_variable_set(:result, result)
end
time_ms() click to toggle source
# File lib/newque/util.rb, line 13
def self.time_ms
  (Time.now.to_f * 1000).to_i
end
wait_t() click to toggle source
# File lib/newque/util.rb, line 25
def self.wait_t
  t = Thread.new do
    while Thread.current.thread_variable_get(:result).nil?
      sleep 0
    end
    Thread.current.thread_variable_get(:result)
  end
  t.priority = -1
  t
end
zmq_error(error) click to toggle source
# File lib/newque/util.rb, line 21
def self.zmq_error error
  NewqueError.new "Network Error: #{error}"
end