diff --git a/couchpotato/api.py b/couchpotato/api.py
index 6cb227da..091de42a 100644
--- a/couchpotato/api.py
+++ b/couchpotato/api.py
@@ -44,6 +44,7 @@ class NonBlockHandler(RequestHandler):
 
     def onNewMessage(self, response):
         if self.request.connection.stream.closed():
+            self.on_connection_close()
             return
 
         try: