+2
-1
app/firehose_stream.rb
+2
-1
app/firehose_stream.rb
···
60
60
61
61
@sky.on_disconnect {
62
62
log "Disconnected."
63
-
save_cursor(sky.cursor)
64
63
}
65
64
66
65
@sky.on_timeout { log "Trying to reconnect..." }
···
73
72
74
73
def stop
75
74
save_queued_posts
75
+
save_cursor(@sky.cursor) unless @sky.nil?
76
+
76
77
@sky&.disconnect
77
78
@sky = nil
78
79
end