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