class RethinkDB::Handler
Public Class Methods
new()
click to toggle source
# File lib/net.rb, line 52 def initialize @stopped = false end
Public Instance Methods
handle(m, args, caller)
click to toggle source
# File lib/net.rb, line 55 def handle(m, args, caller) if !stopped? mar = method(m).arity if mar == args.size send(m, *args) elsif mar == 0 send(m) else send(m, *args, caller) end end end
on_array(arr, caller)
click to toggle source
# File lib/net.rb, line 80 def on_array(arr, caller) if method(:on_atom).owner != Handler handle(:on_atom, [arr], caller) else arr.each {|x| break if stopped? handle(:on_stream_val, [x], caller) } end end
on_atom(val, caller)
click to toggle source
# File lib/net.rb, line 90 def on_atom(val, caller) handle(:on_val, [val], caller) end
on_close(caller)
click to toggle source
# File lib/net.rb, line 70 def on_close(caller) end
on_error(err, caller)
click to toggle source
# File lib/net.rb, line 75 def on_error(err, caller) raise err end
on_open(caller)
click to toggle source
# File lib/net.rb, line 68 def on_open(caller) end
on_stream_val(val, caller)
click to toggle source
# File lib/net.rb, line 93 def on_stream_val(val, caller) handle(:on_val, [val], caller) end
on_unhandled_change(val, caller)
click to toggle source
# File lib/net.rb, line 97 def on_unhandled_change(val, caller) handle(:on_stream_val, [val], caller) end
on_val(val, caller)
click to toggle source
# File lib/net.rb, line 78 def on_val(val, caller) end
on_wait_complete(caller)
click to toggle source
# File lib/net.rb, line 72 def on_wait_complete(caller) end
stop()
click to toggle source
# File lib/net.rb, line 101 def stop @stopped = true end
stopped?()
click to toggle source
# File lib/net.rb, line 104 def stopped? @stopped end