Contents

module PipeRpc
  class Gateway
    def initialize(args)
      @hub = Hub.new(args)
    end

    def channel
      @hub.channel
    end

    def servers
      @hub.servers
    end

    def clients
      @hub.clients
    end

    def loop_iteration=(iteration)
      @hub.requests.wait_for_results_through(iteration)
    end

    def on_sent(&on_sent)
      @hub.socket.on_sent(&on_sent)
    end

    def on_received(&on_received)
      @hub.socket.on_received(&on_received)
    end

    def close
      @hub.socket.close
    end

    def handle_message
      @hub.handle_message
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
pipe_rpc-2.2.1	lib/pipe_rpc/gateway.rb
pipe_rpc-2.2.0	lib/pipe_rpc/gateway.rb
pipe_rpc-2.1.0	lib/pipe_rpc/gateway.rb
pipe_rpc-2.0.0	lib/pipe_rpc/gateway.rb
pipe_rpc-1.1.2	lib/pipe_rpc/gateway.rb
pipe_rpc-1.1.1	lib/pipe_rpc/gateway.rb
pipe_rpc-1.1.0	lib/pipe_rpc/gateway.rb
pipe_rpc-1.0.0	lib/pipe_rpc/gateway.rb