class PipeRpc::Gateway
Attributes
client_wrapper_class_namespace[RW]
subject_server_class_namespace[RW]
Public Class Methods
new(channels)
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 3 def initialize(channels) @hub = Hub.new(self, channels) @client_wrapper_class_namespace = ClientWrappers @subject_server_class_namespace = SubjectServers end
Public Instance Methods
channel()
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 11 def channel @hub.channel end
clients()
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 19 def clients @hub.clients end
close(reason = 'manually closed')
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 47 def close(reason = 'manually closed') @hub.socket.close(reason) end
handle_message()
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 27 def handle_message @hub.handle_message end
loop_iteration=(iteration)
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 23 def loop_iteration=(iteration) @hub.requests.wait_for_results_through(iteration) end
off_received(on_received)
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 43 def off_received(on_received) @hub.socket.off_received(on_received) end
off_sent(on_sent)
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 35 def off_sent(on_sent) @hub.socket.off_sent(on_sent) end
on_received(&on_received)
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 39 def on_received(&on_received) @hub.socket.on_received(&on_received) end
on_sent(&on_sent)
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 31 def on_sent(&on_sent) @hub.socket.on_sent(&on_sent) end
servers()
click to toggle source
# File lib/pipe_rpc/gateway.rb, line 15 def servers @hub.servers end