Method: MessageBus::ConnectionManager#remove_client

Defined in:
lib/message_bus/connection_manager.rb

#remove_client(c) ⇒ Object 



64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/message_bus/connection_manager.rb', line 64

def remove_client(c)
  synchronize do
    @clients.delete c.client_id
    @subscriptions[c.site_id].each do |k, set|
      set.delete c.client_id
    end
    if c.cleanup_timer
      # concurrency may cause this to fail
      c.cleanup_timer.cancel rescue nil
    end
  end
end