Contents

module Faye

  class Transport::Local < Transport
    def self.usable?(dispatcher, endpoint, &callback)
      callback.call(Server === endpoint)
    end

    def batching?
      false
    end

    def request(messages)
      @endpoint.process(messages, nil) do |replies|
        receive(Faye.copy_object(replies))
      end
    end
  end

  Transport.register 'in-process', Transport::Local

end

Version data entries

8 entries across 8 versions & 3 rubygems

Version	Path
faye-1.1.3	lib/faye/transport/local.rb
faye-ouvrages-1.1.2.1	lib/faye/transport/local.rb
faye-ouvrages-1.1.2	lib/faye/transport/local.rb
faye-1.1.2	lib/faye/transport/local.rb
faye-1.1.1	lib/faye/transport/local.rb
faye-1.1.0	lib/faye/transport/local.rb
faye-huboard-1.0.5	lib/faye/transport/local.rb
faye-huboard-1.0.4	lib/faye/transport/local.rb