lib/lite_cable/server/heart_beat.rb in litecable-0.4.2 vs lib/lite_cable/server/heart_beat.rb in litecable-0.5.0
- old
+ new
@@ -1,6 +1,7 @@
# frozen_string_literal: true
+
module LiteCable
module Server
# Sends pings to sockets
class HeartBeat
BEAT_INTERVAL = 3
@@ -20,10 +21,11 @@
def stop
@stopped = true
end
+ # rubocop: disable Metrics/MethodLength
def run
Thread.new do
Thread.current.abort_on_exception = true
loop do
break if @stopped
@@ -37,9 +39,10 @@
sleep BEAT_INTERVAL
end
end
end
+ # rubocop: enable Metrics/MethodLength
private
def ping_message(time)
{ type: LiteCable::INTERNAL[:message_types][:ping], message: time }.to_json