diff --git a/coredis/pubsub.py b/coredis/pubsub.py
index ee73cea8..12a8152d 100644
--- a/coredis/pubsub.py
+++ b/coredis/pubsub.py
@@ -117,7 +117,7 @@ async def _execute(self, connection, command, *args):
                 # when connection is reused
                 connection.disconnect()
 
-            return None
+            raise
         except (ConnectionError, TimeoutError) as e:
             connection.disconnect()