Contents

module Faye
  
  class Transport::Local < Transport
    def self.usable?(endpoint)
      endpoint.is_a?(Server)
    end
    
    def request(message, timeout)
      @endpoint.process(message, true) { |responses| receive(responses) }
    end
  end
  
  Transport.register 'in-process', Transport::Local
  
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
faye-0.6.2	lib/faye/transport/local.rb
faye-0.6.1	lib/faye/transport/local.rb
faye-0.6.0	lib/faye/transport/local.rb