# File lib/faye/engines/connection.rb, line 24 def connect(options, &block) options = options || {} timeout = options['timeout'] ? options['timeout'] / 1000.0 : @engine.timeout set_deferred_status(:unknown) callback(&block) begin_delivery_timeout begin_connection_timeout(timeout) end
# File lib/faye/engines/connection.rb, line 17 def deliver(message) message.delete('clientId') return @socket.send(message) if @socket return unless @inbox.add?(message) begin_delivery_timeout end
# File lib/faye/engines/connection.rb, line 35 def flush remove_timeout(:connection) remove_timeout(:delivery) set_deferred_status(:succeeded, @inbox.entries) @inbox = [] @engine.close_connection(@id) unless @socket end
# File lib/faye/engines/connection.rb, line 10 def initialize(engine, id, options = {}) @engine = engine @id = id @options = options @inbox = Set.new end