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