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