bugfix: Subscription manager breaks on PersistentConnectionClosedOK

Author: fselmo

web3/providers/persistent/async_ipc.py

@@ -110,7 +110,9 @@ async def socket_recv(self) -> RPCResponse:
             raise
 
         if not data:
-            raise PersistentConnectionClosedOK("Socket reader received end of stream.")
+            raise PersistentConnectionClosedOK(
+                user_message="Socket reader received end of stream."
+            )
         return self.decode_rpc_response(data)
 
     # -- private methods -- #

web3/providers/persistent/subscription_manager.py

@@ -298,6 +298,7 @@ async def handle_subscriptions(self, run_forever: bool = False) -> None:
                     "Message listener background task for the provider has stopped "
                     "unexpectedly. Stopping subscription handling."
                 )
+                break
 
         # no active handler subscriptions, clear the handler subscription queue
         self._provider._request_processor._reset_handler_subscription_queue()