1 files changed, 2 insertions, 2 deletions
diff --git a/src/com/isode/stroke/network/Connector.java b/src/com/isode/stroke/network/Connector.java
index 2823679..73a478b 100644
--- a/src/com/isode/stroke/network/Connector.java
+++ b/src/com/isode/stroke/network/Connector.java
@@ -218,9 +218,9 @@ public class Connector {
                addressQuery.onResult.disconnectAll();
                addressQuery = null;
        }
-        if (currentConnection != null) {
+        if (currentConnectionConnectFinishedConnection != null) {
                currentConnectionConnectFinishedConnection.disconnect();
-                currentConnection = null;
+                currentConnectionConnectFinishedConnection = null;
        }
        onConnectFinished.emit(connection, (connection != null || foundSomeDNS) ? null : new DomainNameResolveError());

diff --git a/src/com/isode/stroke/network/Connector.java b/src/com/isode/stroke/network/Connector.java index 2823679..73a478b 100644 --- a/src/com/isode/stroke/network/Connector.java +++ b/src/com/isode/stroke/network/Connector.java
@@ -218,9 +218,9 @@ public class Connector {
218	addressQuery.onResult.disconnectAll();	218	addressQuery.onResult.disconnectAll();
219	addressQuery = null;	219	addressQuery = null;
220	}	220	}
221	if (currentConnection != null) {	221	if (currentConnectionConnectFinishedConnection != null) {
222	currentConnectionConnectFinishedConnection.disconnect();	222	currentConnectionConnectFinishedConnection.disconnect();
223	currentConnection = null;	223	currentConnectionConnectFinishedConnection = null;
224	}	224	}
225		225
226	onConnectFinished.emit(connection, (connection != null \|\| foundSomeDNS) ? null : new DomainNameResolveError());	226	onConnectFinished.emit(connection, (connection != null \|\| foundSomeDNS) ? null : new DomainNameResolveError());