Contents

module Faye

  class Transport::Local < Transport
    def self.usable?(client, 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

3 entries across 3 versions & 2 rubygems

Version	Path
faye-0.8.11	lib/faye/transport/local.rb
face-faye-0.8.9	lib/faye/transport/local.rb
faye-0.8.9	lib/faye/transport/local.rb