class Floss::RPC::InMemory::Client
Attributes
address[RW]
Public Class Methods
new(address)
click to toggle source
# File lib/floss/rpc/in_memory.rb, line 9 def initialize(address) self.address = address end
Public Instance Methods
actor()
click to toggle source
# File lib/floss/rpc/in_memory.rb, line 19 def actor Celluloid::Actor[address] end
call(command, payload)
click to toggle source
# File lib/floss/rpc/in_memory.rb, line 13 def call(command, payload) timeout(Floss::RPC::TIMEOUT) { actor.execute(command, payload) } rescue Celluloid::DeadActorError, Celluloid::Task::TimeoutError raise Floss::TimeoutError end