Method: ActionCable::SubscriptionAdapter::PostgreSQL::Listener#initialize

Defined in:
actioncable/lib/action_cable/subscription_adapter/postgresql.rb

#initialize(adapter, event_loop) ⇒ Listener

Returns a new instance of Listener.



76
77
78
79
80
81
82
83
84
85
86
87
 
# File 'actioncable/lib/action_cable/subscription_adapter/postgresql.rb', line 76

def initialize(adapter, event_loop)
  super()

  @adapter = adapter
  @event_loop = event_loop
  @queue = Queue.new

  @thread = Thread.new do
    Thread.current.abort_on_exception = true
    listen
  end
end