class Liebre::Actor::RPC::Server
Constants
- OPTS
Attributes
context[R]
Public Class Methods
new(context)
click to toggle source
Calls superclass method
# File lib/liebre/actor/rpc/server.rb, line 16 def initialize context super() @context = context end
Public Instance Methods
__clean__()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 51 def __clean__ reporter.on_clean { core.clean() } end
__failed__(meta, error)
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 47 def __failed__(meta, error) reporter.on_failed(error) { core.failed(meta, error) } end
__handle__(meta, payload)
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 39 def __handle__(meta, payload) reporter.on_handle { core.handle(meta, payload) } end
__reply__(meta, response, opts)
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 43 def __reply__(meta, response, opts) reporter.on_reply { core.reply(meta, response, opts) } end
__start__()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 32 def __start__() reporter.on_start { core.start } end
__stop__()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 35 def __stop__() reporter.on_stop { core.stop } end
clean()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 30 def clean() async.__clean__(); end
failed(meta, error)
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 28 def failed(meta, error) async.__failed__(meta, error); end
handle(meta, payload)
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 25 def handle(meta, payload) async.__handle__(meta, payload); end
reply(meta, response, opts = {})
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 27 def reply(meta, response, opts = {}) async.__reply__(meta, response, opts); end
start()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 22 def start() async.__start__(); end
stop()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 23 def stop() async.__stop__(); end
Private Instance Methods
core()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 57 def core @core ||= Core.new(self, resources, context, Callback) end
reporter()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 65 def reporter @reporter ||= Reporter.new(context) end
resources()
click to toggle source
# File lib/liebre/actor/rpc/server.rb, line 61 def resources Resources.new(context) end