class Liebre::Actor::RPC::Client

Constants

TIMEOUT

Attributes

context[R]

Public Class Methods

new(context) click to toggle source
Calls superclass method
# File lib/liebre/actor/rpc/client.rb, line 17
def initialize context
  super()

  @context = context
end

Public Instance Methods

__clean__() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 57
def __clean__()
  reporter.on_clean { core.clean() }
end
__expire__() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 53
def __expire__()
  reporter.on_expire { core.expire() }
end
__reply__(meta, response) click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 49
def __reply__(meta, response)
  reporter.on_reply { core.reply(meta, response) }
end
__request__(payload, opts, timeout) click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 45
def __request__(payload, opts, timeout)
  reporter.on_request { core.request(payload, opts, timeout) }
end
__start__() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 38
def __start__()
  reporter.on_start { core.start }
end
__stop__() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 41
def __stop__()
  reporter.on_stop { core.stop }
end
clean() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 36
def clean() async.__clean__(); end
expire() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 34
def expire() async.__expire__(); end
reply(meta, response) click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 32
def reply(meta, response) async.__reply__(meta, response); end
request(payload, opts = {}) click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 26
def request payload, opts = {}, timeout = TIMEOUT
  call_ivar     = await.__request__(payload, opts, timeout)
  response_ivar = call_ivar.value

  response_ivar.value(timeout)
end
start() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 23
def start() async.__start__(); end
stop() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 24
def stop()  async.__stop__();  end

Private Instance Methods

core() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 63
def core
  @core ||= Core.new(self, resources, context, pending, task)
end
pending() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 71
def pending
  Pending.new
end
reporter() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 79
def reporter
  @reporter ||= Reporter.new(context)
end
resources() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 67
def resources
  Resources.new(context)
end
task() click to toggle source
# File lib/liebre/actor/rpc/client.rb, line 75
def task
  Task.new
end