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