class Bones::RPC::Synchronous::Node
Represents a client to a node in a server cluster.
@since 0.0.1
Public Class Methods
new(*args)
click to toggle source
Calls superclass method
Bones::RPC::Node::new
# File lib/bones/rpc/synchronous/node.rb, line 38 def initialize(*args) @mutex = ::Mutex.new super(*args) end
Public Instance Methods
abort(cause)
click to toggle source
Compatability with Celluloid
# File lib/bones/rpc/synchronous/node.rb, line 16 def abort(cause) raise cause end
async()
click to toggle source
# File lib/bones/rpc/synchronous/node.rb, line 20 def async self end
connection() { |connection| ... }
click to toggle source
# File lib/bones/rpc/synchronous/node.rb, line 28 def connection @mutex.synchronize do if block_given? yield @connection else @connection end end end
current_actor()
click to toggle source
# File lib/bones/rpc/synchronous/node.rb, line 24 def current_actor self end