mackuba.eu
+6
-3
app/firehose_stream.rb
+6
-3
app/firehose_stream.rb
···
37
38
if @log_status
39
@sky.on_connecting { |u| puts "Connecting to #{u}..." }
40
-
@sky.on_connect { @replaying = !!(cursor); puts "Connected #{Time.now} ✓" }
41
@sky.on_disconnect { puts; puts "Disconnected #{Time.now}" }
42
-
@sky.on_reconnect { puts "Reconnecting..." }
43
-
@sky.on_error { |e| puts "ERROR: #{Time.now} #{e}" }
44
end
45
46
@sky.connect
···
37
38
if @log_status
39
@sky.on_connecting { |u| puts "Connecting to #{u}..." }
40
+
@sky.on_connect {
41
+
@replaying = !!(cursor)
42
+
puts "Connected #{Time.now} ✓"
43
+
}
44
@sky.on_disconnect { puts; puts "Disconnected #{Time.now}" }
45
+
@sky.on_reconnect { puts "Connection lost, reconnecting..." }
46
+
@sky.on_error { |e| puts "ERROR: #{Time.now} #{e.class} #{e.message}" }
47
end
48
49
@sky.connect