class Bones::RPC::Synchronous::Connection::Writer::NodeProxy
Public Class Methods
new(node)
click to toggle source
# File lib/bones/rpc/synchronous/connection/writer.rb, line 66 def initialize(node) @node = node @registry = Node::Registry.new end
Public Instance Methods
attach(channel, id, future)
click to toggle source
# File lib/bones/rpc/synchronous/connection/writer.rb, line 50 def attach(channel, id, future) @registry.set(channel, id, future) end
detach(channel, id)
click to toggle source
# File lib/bones/rpc/synchronous/connection/writer.rb, line 54 def detach(channel, id) @registry.get(channel, id) end
handle_message(message)
click to toggle source
# File lib/bones/rpc/synchronous/connection/writer.rb, line 58 def handle_message(message) logging(message) do if future = message.get(self) message.signal(future) end end end
registry_empty?()
click to toggle source
# File lib/bones/rpc/synchronous/connection/writer.rb, line 71 def registry_empty? @registry.empty? end
Protected Instance Methods
method_missing(name, *args, &block)
click to toggle source
# File lib/bones/rpc/synchronous/connection/writer.rb, line 77 def method_missing(name, *args, &block) @node.__send__(name, *args, &block) end