class ActionCable::SubscriptionAdapter::PostgreSQL

def listener
  @listener || @server.mutex.synchronize { @listener ||= Listener.new(self, @server.event_loop) }
end