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