diff --git a/lib/electrumx_rpc/electrumx.dart b/lib/electrumx_rpc/electrumx.dart
index fe4bb1796..9a2f19d75 100644
--- a/lib/electrumx_rpc/electrumx.dart
+++ b/lib/electrumx_rpc/electrumx.dart
@@ -15,8 +15,10 @@ import 'dart:io';
 import 'package:connectivity_plus/connectivity_plus.dart';
 import 'package:decimal/decimal.dart';
 import 'package:event_bus/event_bus.dart';
+import 'package:mutex/mutex.dart';
 import 'package:stackwallet/electrumx_rpc/rpc.dart';
 import 'package:stackwallet/exceptions/electrumx/no_such_transaction.dart';
+import 'package:stackwallet/services/event_bus/events/global/tor_connection_status_changed_event.dart';
 import 'package:stackwallet/services/event_bus/events/global/tor_status_changed_event.dart';
 import 'package:stackwallet/services/event_bus/global_event_bus.dart';
 import 'package:stackwallet/services/tor_service.dart';
@@ -80,9 +82,15 @@ class ElectrumX {
   // add finalizer to cancel stream subscription when all references to an
   // instance of ElectrumX becomes inaccessible
   static final Finalizer<ElectrumX> _finalizer = Finalizer(
-    (p0) => p0._torStatusListener?.cancel(),
+    (p0) {
+      p0._torPreferenceListener?.cancel();
+      p0._torStatusListener?.cancel();
+    },
   );
-  StreamSubscription<TorPreferenceChangedEvent>? _torStatusListener;
+  StreamSubscription<TorPreferenceChangedEvent>? _torPreferenceListener;
+  StreamSubscription<TorConnectionStatusChangedEvent>? _torStatusListener;
+
+  final Mutex _torConnectingLock = Mutex();
 
   ElectrumX({
     required String host,
@@ -104,7 +112,21 @@ class ElectrumX {
     _rpcClient = client;
 
     final bus = globalEventBusForTesting ?? GlobalEventBus.instance;
-    _torStatusListener = bus.on<TorPreferenceChangedEvent>().listen(
+    _torStatusListener = bus.on<TorConnectionStatusChangedEvent>().listen(
+      (event) async {
+        switch (event.newStatus) {
+          case TorConnectionStatus.connecting:
+            await _torConnectingLock.acquire();
+            break;
+
+          case TorConnectionStatus.connected:
+          case TorConnectionStatus.disconnected:
+            _torConnectingLock.release();
+            break;
+        }
+      },
+    );
+    _torPreferenceListener = bus.on<TorPreferenceChangedEvent>().listen(
       (event) async {
         // not sure if we need to do anything specific here
         // switch (event.status) {
@@ -238,7 +260,7 @@ class ElectrumX {
       throw WifiOnlyException();
     }
 
-    _checkRpcClient();
+    await _torConnectingLock.protect(() async => _checkRpcClient());
 
     try {
       final requestId = requestID ?? const Uuid().v1();
@@ -324,7 +346,7 @@ class ElectrumX {
       throw WifiOnlyException();
     }
 
-    _checkRpcClient();
+    await _torConnectingLock.protect(() async => _checkRpcClient());
 
     try {
       final List<String> requestStrings = [];