Class: AcpcTableManager::ProxyCommunicator

Inherits:
Object
  • Object
show all
Defined in:
lib/acpc_table_manager.rb

Instance Method Summary collapse

Constructor Details

#initialize(id) ⇒ ProxyCommunicator

Returns a new instance of ProxyCommunicator.



81
82
83
84
 
# File 'lib/acpc_table_manager.rb', line 81

def initialize(id)
  @sender = Sender.new(id)
  @receiver = ProxyReceiver.new(id)
end

Instance Method Details

#del_saved ⇒ Object 



91
92
93
94
 
# File 'lib/acpc_table_manager.rb', line 91

def del_saved
  @receiver.del
  @sender.del
end

#publish(data) ⇒ Object 



85
 
# File 'lib/acpc_table_manager.rb', line 85

def publish(data) @sender.publish(data) end

#receive_channel ⇒ Object 



90
 
# File 'lib/acpc_table_manager.rb', line 90

def receive_channel() @receiver.channel end

#send_channel ⇒ Object 



89
 
# File 'lib/acpc_table_manager.rb', line 89

def send_channel() @sender.channel end

#subscribe_with_timeout ⇒ Object 



86
87
88
 
# File 'lib/acpc_table_manager.rb', line 86

def subscribe_with_timeout
  @receiver.subscribe_with_timeout { |on| yield on }
end