+2
-2
app/firehose_stream.rb
+2
-2
app/firehose_stream.rb
···
76
76
# puts "Handle change: #{msg.repo} => #{msg.handle}"
77
77
elsif msg.is_a?(Skyfall::UnknownMessage)
78
78
puts "Unknown message type: #{msg.type}"
79
-
elsif msg.type != :commit
80
-
return
81
79
end
80
+
81
+
return unless msg.type == :commit
82
82
83
83
if @replaying
84
84
puts "Replaying events since #{msg.time.getlocal} -->"