Sha256: 04fddb65300e06fa134fa03adc7f80619fe1495f121264f9c24c644117c497c4

Contents?: true

Size: 455 Bytes

Versions: 10

Compression:

Stored size: 455 Bytes

Contents

module Faye
  
  class Transport::Local < Transport
    def self.usable?(endpoint, &callback)
      callback.call(endpoint.is_a?(Server))
    end
    
    def batching?
      false
    end
    
    def request(message, timeout)
      message = Faye.copy_object(message)
      @endpoint.process(message, true) do |responses|
        receive(Faye.copy_object(responses))
      end
    end
  end
  
  Transport.register 'in-process', Transport::Local
  
end

Version data entries

10 entries across 10 versions & 3 rubygems

Version Path
faye-0.7.2 lib/faye/transport/local.rb
faye-0.8.3 lib/faye/transport/local.rb
faye-0.8.2 lib/faye/transport/local.rb
_bushido-faye-0.8.2 lib/faye/transport/local.rb
_bushido-faye-0.8.1 lib/faye/transport/local.rb
bushido-faye-0.8.1 lib/faye/transport/local.rb
faye-0.8.1 lib/faye/transport/local.rb
faye-0.8.0 lib/faye/transport/local.rb
faye-0.7.1 lib/faye/transport/local.rb
faye-0.7.0 lib/faye/transport/local.rb