blob: 2918938ba53a5fc63d57f08f67b592254eea8ead (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
module ActionCable
module Connection
# Websocket connection implementations differ on when they'll mark a connection as stale. We basically never want a connection to go stale, as you
# then can't rely on being able to receive and send to it. So there's a 3 second heartbeat running on all connections. If the beat fails, we automatically
# disconnect.
class Heartbeat
BEAT_INTERVAL = 3
def initialize(connection)
@connection = connection
end
def start
beat
@timer = EventMachine.add_periodic_timer(BEAT_INTERVAL) { beat }
end
def stop
EventMachine.cancel_timer(@timer) if @timer
end
private
attr_reader :connection
def beat
connection.transmit({ identifier: '_ping', message: Time.now.to_i }.to_json)
end
end
end
end
|
