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