Class: Faye::Engine::Connection

Inherits:

Object

• Object
• Faye::Engine::Connection

show all

Includes:

EventMachine::Deferrable, Timeouts

Defined in:

lib/faye/engines/connection.rb

Instance Attribute Summary (collapse)

• - (Object) id readonly

  Returns the value of attribute id.

Instance Method Summary (collapse)

• - (Object) connect(options, &block)
• - (Object) deliver(message)
• - (Object) flush!
• - (Connection) initialize(engine, id, options = {}) constructor

  A new instance of Connection.

Methods included from Timeouts

#add_timeout, #remove_timeout

10
11
12
13
14
15

# File 'lib/faye/engines/connection.rb', line 10

def initialize(engine, id, options = {})
  @engine  = engine
  @id      = id
  @options = options
  @inbox   = Set.new
end

8
9
10

# File 'lib/faye/engines/connection.rb', line 8

def id
  @id
end

22
23
24
25
26
27
28
29
30
31
32
33
34
35

# File 'lib/faye/engines/connection.rb', line 22

def connect(options, &block)
  options = options || {}
  timeout = options['timeout'] ? options['timeout'] / 1000.0 : @engine.timeout
  
  set_deferred_status(:deferred)
  
  callback(&block)
  return if @connected
  
  @connected = true
  
  begin_delivery_timeout
  begin_connection_timeout(timeout)
end

17
18
19
20

# File 'lib/faye/engines/connection.rb', line 17

def deliver(message)
  return unless @inbox.add?(message)
  begin_delivery_timeout
end

37
38
39
40

# File 'lib/faye/engines/connection.rb', line 37

def flush!
  release_connection!
  set_deferred_status(:succeeded, @inbox.entries)
end