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