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