diff --git a/lib/gerrit_notifier.rb b/lib/gerrit_notifier.rb
index 66f2429..e85ecd0 100644
--- a/lib/gerrit_notifier.rb
+++ b/lib/gerrit_notifier.rb
@@ -73,9 +73,11 @@ def self.listen_for_updates
     stream = YAML.load(File.read('config/gerrit.yml'))['gerrit']['stream']
     puts "Listening to stream via #{stream}"
 
-    IO.popen(stream).each do |line|
-      update = Update.new(line)
-      process_update(update)
+    IO.popen(stream) do |p|
+      p.each do |line|
+        update = Update.new(line)
+        process_update(update)
+      end
     end
 
     puts "Connection to Gerrit server failed, trying to reconnect."