class Unrestful::RpcController
Attributes
async[R]
job[R]
live[R]
method[R]
request[R]
response[R]
service[R]
Protected Class Methods
after_method(method, options = {})
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 43 def self.after_method(method, options = {}) self.after_method_callbacks = {method => options} end
async(async_list)
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 55 def self.async(async_list) self.async_methods = async_list end
before_method(method, options = {})
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 39 def self.before_method(method, options = {}) self.before_method_callbacks = {method => options} end
live(live_list)
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 51 def self.live(live_list) self.live_methods = live_list end
scopes(scope_list)
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 47 def self.scopes(scope_list) self.assigned_scopes = ActiveSupport::HashWithIndifferentAccess.new(scope_list) end
Public Instance Methods
after_callbacks()
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 25 def after_callbacks self.class.after_method_callbacks.each do |k, v| self.send(k) end end
before_callbacks()
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 18 def before_callbacks self.class.before_method_callbacks.each do |k, v| # no checks for now self.send(k) end end
write(message)
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 31 def write(message) raise NotLiveError unless live msg = message.end_with?("\n") ? message : "#{message}\n" response.stream.write msg end
Protected Instance Methods
fail!(message = "")
click to toggle source
# File lib/unrestful/rpc_controller.rb, line 59 def fail!(message = "") raise ::Unrestful::FailError, message end