diff --git a/lnbits/wallets/clightning.py b/lnbits/wallets/clightning.py
index c1b10220..1dd5cc3c 100644
--- a/lnbits/wallets/clightning.py
+++ b/lnbits/wallets/clightning.py
@@ -115,7 +115,7 @@ class CLightningWallet(Wallet):
         raise KeyError("supplied an invalid checking_id")
 
     async def paid_invoices_stream(self) -> AsyncGenerator[str, None]:
-        stream = await asyncio.open_unix_socket(self.rpc)
+        stream = await asyncio.open_unix_connection(self.rpc)
 
         i = 0
         while True: