Class: Liebre::Actor::RPC::Server

Inherits:
Object
  • Object
show all
Includes:
Concurrent::Async
Defined in:
lib/liebre/actor/rpc/server.rb,
lib/liebre/actor/rpc/server/core.rb,
lib/liebre/actor/rpc/server/callback.rb,
lib/liebre/actor/rpc/server/reporter.rb,
lib/liebre/actor/rpc/server/resources.rb

Defined Under Namespace

Classes: Callback, Core, Reporter, Resources

Constant Summary collapse

OPTS = 
{:block => false, :manual_ack => false}

Instance Method Summary collapse

Constructor Details

#initialize(context) ⇒ Server

Returns a new instance of Server.



16
17
18
19
20
 
# File 'lib/liebre/actor/rpc/server.rb', line 16

def initialize context
  super()

  @context = context
end

Instance Method Details

#__clean__ ⇒ Object 



51
52
53
 
# File 'lib/liebre/actor/rpc/server.rb', line 51

def __clean__
  reporter.on_clean { core.clean() }
end

#__failed__(meta, error) ⇒ Object 



47
48
49
 
# 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) ⇒ Object 



39
40
41
 
# 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) ⇒ Object 



43
44
45
 
# File 'lib/liebre/actor/rpc/server.rb', line 43

def __reply__(meta, response, opts)
  reporter.on_reply { core.reply(meta, response, opts) }
end

#__start__ ⇒ Object 



32
33
34
 
# File 'lib/liebre/actor/rpc/server.rb', line 32

def __start__()
  reporter.on_start { core.start }
end

#__stop__ ⇒ Object 



35
36
37
 
# File 'lib/liebre/actor/rpc/server.rb', line 35

def __stop__()
  reporter.on_stop { core.stop }
end

#clean ⇒ Object 



30
 
# File 'lib/liebre/actor/rpc/server.rb', line 30

def clean() async.__clean__(); end

#failed(meta, error) ⇒ Object 



28
 
# File 'lib/liebre/actor/rpc/server.rb', line 28

def failed(meta, error)              async.__failed__(meta, error);         end

#handle(meta, payload) ⇒ Object 



25
 
# File 'lib/liebre/actor/rpc/server.rb', line 25

def handle(meta, payload) async.__handle__(meta, payload); end

#reply(meta, response, opts = {}) ⇒ Object 



27
 
# File 'lib/liebre/actor/rpc/server.rb', line 27

def reply(meta, response, opts = {}) async.__reply__(meta, response, opts); end

#start ⇒ Object 



22
 
# File 'lib/liebre/actor/rpc/server.rb', line 22

def start() async.__start__(); end

#stop ⇒ Object 



23
 
# File 'lib/liebre/actor/rpc/server.rb', line 23

def stop()  async.__stop__();  end