fix(transit): when transit disconnect, always call transporter.discon…

…nect()
moleculerjs · Nov 17, 2023 · 2040693 · 2040693
1 parent 6a58b17
commit 2040693
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/transit.js b/src/transit.js
@@ -231,10 +231,9 @@ class Transit {
 
 		return this.Promise.resolve()
 			.then(() => {
-				if (this.tx.connected) {
-					return this.discoverer.localNodeDisconnected().then(() => this.tx.disconnect());
-				}
+				return this.tx.connected && this.discoverer.localNodeDisconnected();
 			})
+			.then(() => this.tx.disconnect())
 			.then(() => (this.disconnecting = false));
 	}