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