Start connection in background thread

Author: Gurgen

app/src/main/java/com/smartarmenia/websocketclient/MainActivity.kt

@@ -26,7 +26,7 @@ class MainActivity : AppCompatActivity(), HubConnectionListener, HubEventListene
     }
 
     override fun onError(exception: Exception) {
-
+        runOnUiThread { Toast.makeText(this@MainActivity, exception.message, Toast.LENGTH_SHORT).show() }
     }
 
     private val connection: HubConnection = WebSocketHubConnection("http://192.168.0.104:5002/signalr/hubs/auth")
@@ -36,22 +36,14 @@ class MainActivity : AppCompatActivity(), HubConnectionListener, HubEventListene
         setContentView(R.layout.activity_main)
 
         btnHello.setOnClickListener {
-            connection.invoke("Send", "Hello")
-        }
-
-        Thread(Runnable {
             try {
-                connection.connect("Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1bmlxdWVfbmFtZSI6Ijc5NzhjMjI3LWViMGItNGMwOS1iYWEyLTEwYmE0MjI4YWE4OSIsImNlcnRzZXJpYWxudW1iZXIiOiJtYWNfYWRkcmVzc19vZl9waG9uZSIsInNlY3VyaXR5U3RhbXAiOiJlMTAxOWNiYy1jMjM2LTQ0ZTEtYjdjYy0zNjMxYTYxYzMxYmIiLCJuYmYiOjE1MDYyODQ4NzMsImV4cCI6NDY2MTk1ODQ3MywiaWF0IjoxNTA2Mjg0ODczLCJpc3MiOiJCbGVuZCIsImF1ZCI6IkJsZW5kIn0.QUh241IB7g3axLcfmKR2899Kt1xrTInwT6BBszf6aP4")
-            } catch (ex: Exception) {
-                runOnUiThread { Toast.makeText(this@MainActivity, ex.message, Toast.LENGTH_SHORT).show() }
+                connection.invoke("Send", "Hello")
+            } catch (e: Exception) {
+                Toast.makeText(this@MainActivity, e.message, Toast.LENGTH_SHORT).show()
             }
-            connection.addListener(this@MainActivity)
-            connection.subscribeToEvent("Send", this)
-        }).start()
+        }
 
-        Thread(Runnable {
-            connect()
-        }).start()
+        connect()
     }
 
     override fun onDestroy() {

dotnetcoresignalrclientjava/bintray.gradle

@@ -1,6 +1,6 @@
 apply plugin: 'com.jfrog.bintray'
 
-version = '1.0.6'
+version = '1.07'
 
 task sourcesJar(type: Jar) {
     from android.sourceSets.main.java.srcDirs

dotnetcoresignalrclientjava/build.gradle

@@ -8,8 +8,8 @@ android {
     defaultConfig {
         minSdkVersion 16
         targetSdkVersion 26
-        versionCode 7
-        versionName "1.06"
+        versionCode 8
+        versionName "1.07"
     }
 
     buildTypes {

dotnetcoresignalrclientjava/src/main/java/com/smartarmenia/dotnetcoresignalrclientjava/WebSocketHubConnection.java

@@ -41,7 +41,16 @@ public WebSocketHubConnection(String hubUrl) {
     }
 
     @Override
-    public void connect(String authHeader) {
+    public void connect(final String authHeader) {
+        Runnable runnable = new Runnable() {
+            public void run() {
+                getConnectionId(authHeader);
+            }
+        };
+        new Thread(runnable).start();
+    }
+
+    private void getConnectionId(String authHeader) {
         Log.i(TAG, "Requesting connection id...");
         if (!(parsedUri.getScheme().equals("http") || parsedUri.getScheme().equals("https")))
             throw new RuntimeException("URL must start with http or https");
@@ -126,18 +135,28 @@ public void onClose(int code, String reason, boolean remote) {
             @Override
             public void onError(Exception ex) {
                 Log.i(TAG, "Error " + ex.getMessage());
-                for (HubConnectionListener listener : listeners) {
-                    listener.onError(ex);
-                }
+                error(ex);
             }
         };
         Log.i(TAG, "Connecting...");
         client.connect();
     }
 
+    private void error(Exception ex) {
+        for (HubConnectionListener listener : listeners) {
+            listener.onError(ex);
+        }
+    }
+
     @Override
     public void disconnect() {
-        client.close();
+        Runnable runnable = new Runnable() {
+            public void run() {
+                if (client != null && !(client.isClosed() || client.isClosing()))
+                    client.close();
+            }
+        };
+        new Thread(runnable).start();
     }
 
     @Override
@@ -175,13 +194,25 @@ public void unSubscribeFromEvent(String eventName, HubEventListener eventListene
 
     @Override
     public void invoke(String event, Object... parameters) {
-        Map<String, Object> map = new HashMap<>();
+        if (client == null || !client.isOpen()) {
+            throw new RuntimeException("Not connected");
+        }
+        final Map<String, Object> map = new HashMap<>();
         map.put("type", 1);
         map.put("invocationId", UUID.randomUUID());
         map.put("target", event);
         map.put("arguments", parameters);
         map.put("nonblocking", false);
-        client.send(gson.toJson(map) + SPECIAL_SYMBOL);
+        Runnable runnable = new Runnable() {
+            public void run() {
+                try {
+                    client.send(gson.toJson(map) + SPECIAL_SYMBOL);
+                } catch (Exception e) {
+                    error(e);
+                }
+            }
+        };
+        new Thread(runnable).start();
     }
 
     private static class InputStreamConverter {