diff --git a/src/services/lnd/swaps/reverseSwaps.ts b/src/services/lnd/swaps/reverseSwaps.ts
index 14dc4d44..83dddc37 100644
--- a/src/services/lnd/swaps/reverseSwaps.ts
+++ b/src/services/lnd/swaps/reverseSwaps.ts
@@ -155,9 +155,7 @@ export class ReverseSwaps {
                 }
             } catch (err: any) {
                 this.log(ERROR, 'Error handling transaction WebSocket message', err.message)
-                isDone = true
-                webSocket.close()
-                swapDone({ ok: false, error: err.message })
+                done(err.message)
                 return
             }
         })
diff --git a/src/services/lnd/swaps/submarineSwaps.ts b/src/services/lnd/swaps/submarineSwaps.ts
index 32ed1fac..462f4751 100644
--- a/src/services/lnd/swaps/submarineSwaps.ts
+++ b/src/services/lnd/swaps/submarineSwaps.ts
@@ -407,7 +407,7 @@ export class SubmarineSwaps {
                 await this.handleSwapInvoiceMessage(rawMsg, data, done, waitingTx)
             } catch (err: any) {
                 this.log(ERROR, 'Error handling invoice WebSocket message', err.message)
-                webSocket.close()
+                done(err.message)
                 return
             }
         });