Init web socket clients lazily (#912)

Author: Mykola Mokhnach

src/main/java/io/appium/java_client/android/AndroidDriver.java

@@ -35,6 +35,7 @@
 import io.appium.java_client.screenrecording.CanRecordScreen;
 import io.appium.java_client.service.local.AppiumDriverLocalService;
 import io.appium.java_client.service.local.AppiumServiceBuilder;
+import io.appium.java_client.ws.StringWebSocketClient;
 import org.openqa.selenium.Capabilities;
 import org.openqa.selenium.WebElement;
 import org.openqa.selenium.remote.HttpCommandExecutor;
@@ -66,6 +67,8 @@ public class AndroidDriver<T extends WebElement>
 
     private static final String ANDROID_PLATFORM = MobilePlatform.ANDROID;
 
+    private StringWebSocketClient logcatClient;
+
     /**
      * Creates a new instance based on command {@code executor} and {@code capabilities}.
      *
@@ -193,4 +196,12 @@ public AndroidBatteryInfo getBatteryInfo() {
         return new AndroidBatteryInfo((Map<String, Object>) execute(EXECUTE_SCRIPT, ImmutableMap.of(
                 "script", "mobile: batteryInfo", "args", Collections.emptyList())));
     }
+
+    @Override
+    public synchronized StringWebSocketClient getLogcatClient() {
+        if (logcatClient == null) {
+            logcatClient = new StringWebSocketClient();
+        }
+        return logcatClient;
+    }
 }

src/main/java/io/appium/java_client/android/ListensToLogcatMessages.java

@@ -31,7 +31,7 @@
 import java.util.function.Consumer;
 
 public interface ListensToLogcatMessages extends ExecutesMethod {
-    StringWebSocketClient logcatClient = new StringWebSocketClient();
+    StringWebSocketClient getLogcatClient();
 
     /**
      * Start logcat messages broadcast via web socket.
@@ -68,7 +68,7 @@ default void startLogcatBroadcast(String host, int port) {
         } catch (URISyntaxException e) {
             throw new IllegalArgumentException(e);
         }
-        logcatClient.connect(endpointUri);
+        getLogcatClient().connect(endpointUri);
     }
 
     /**
@@ -80,7 +80,7 @@ default void startLogcatBroadcast(String host, int port) {
      * @param handler a function, which accepts a single argument, which is the actual log message
      */
     default void addLogcatMessagesListener(Consumer<String> handler) {
-        logcatClient.addMessageHandler(handler);
+        getLogcatClient().addMessageHandler(handler);
     }
 
     /**
@@ -92,7 +92,7 @@ default void addLogcatMessagesListener(Consumer<String> handler) {
      * @param handler a function, which accepts a single argument, which is the actual exception instance
      */
     default void addLogcatErrorsListener(Consumer<Throwable> handler) {
-        logcatClient.addErrorHandler(handler);
+        getLogcatClient().addErrorHandler(handler);
     }
 
     /**
@@ -105,7 +105,7 @@ default void addLogcatErrorsListener(Consumer<Throwable> handler) {
      *                connected to the web socket
      */
     default void addLogcatConnectionListener(Runnable handler) {
-        logcatClient.addConnectionHandler(handler);
+        getLogcatClient().addConnectionHandler(handler);
     }
 
     /**
@@ -118,14 +118,14 @@ default void addLogcatConnectionListener(Runnable handler) {
      *                disconnected from the web socket
      */
     default void addLogcatDisconnectionListener(Runnable handler) {
-        logcatClient.addDisconnectionHandler(handler);
+        getLogcatClient().addDisconnectionHandler(handler);
     }
 
     /**
      * Removes all existing logcat handlers.
      */
     default void removeAllLogcatListeners() {
-        logcatClient.removeAllHandlers();
+        getLogcatClient().removeAllHandlers();
     }
 
     /**

src/main/java/io/appium/java_client/ios/IOSDriver.java

@@ -34,6 +34,7 @@
 import io.appium.java_client.screenrecording.CanRecordScreen;
 import io.appium.java_client.service.local.AppiumDriverLocalService;
 import io.appium.java_client.service.local.AppiumServiceBuilder;
+import io.appium.java_client.ws.StringWebSocketClient;
 import org.openqa.selenium.Alert;
 import org.openqa.selenium.Capabilities;
 import org.openqa.selenium.WebElement;
@@ -68,6 +69,8 @@ public class IOSDriver<T extends WebElement>
 
     private static final String IOS_PLATFORM = MobilePlatform.IOS;
 
+    private StringWebSocketClient syslogClient;
+
     /**
      * Creates a new instance based on command {@code executor} and {@code capabilities}.
      *
@@ -225,4 +228,12 @@ class IOSAlert implements Alert {
         }
 
     }
+
+    @Override
+    public synchronized StringWebSocketClient getSyslogClient() {
+        if (syslogClient == null) {
+            syslogClient = new StringWebSocketClient();
+        }
+        return syslogClient;
+    }
 }

src/main/java/io/appium/java_client/ios/ListensToSyslogMessages.java

@@ -31,7 +31,8 @@
 import java.util.function.Consumer;
 
 public interface ListensToSyslogMessages extends ExecutesMethod {
-    StringWebSocketClient syslogClient = new StringWebSocketClient();
+
+    StringWebSocketClient getSyslogClient();
 
     /**
      * Start syslog messages broadcast via web socket.
@@ -68,7 +69,7 @@ default void startSyslogBroadcast(String host, int port) {
         } catch (URISyntaxException e) {
             throw new IllegalArgumentException(e);
         }
-        syslogClient.connect(endpointUri);
+        getSyslogClient().connect(endpointUri);
     }
 
     /**
@@ -80,7 +81,7 @@ default void startSyslogBroadcast(String host, int port) {
      * @param handler a function, which accepts a single argument, which is the actual log message
      */
     default void addSyslogMessagesListener(Consumer<String> handler) {
-        syslogClient.addMessageHandler(handler);
+        getSyslogClient().addMessageHandler(handler);
     }
 
     /**
@@ -92,7 +93,7 @@ default void addSyslogMessagesListener(Consumer<String> handler) {
      * @param handler a function, which accepts a single argument, which is the actual exception instance
      */
     default void addSyslogErrorsListener(Consumer<Throwable> handler) {
-        syslogClient.addErrorHandler(handler);
+        getSyslogClient().addErrorHandler(handler);
     }
 
     /**
@@ -105,7 +106,7 @@ default void addSyslogErrorsListener(Consumer<Throwable> handler) {
      *                connected to the web socket
      */
     default void addSyslogConnectionListener(Runnable handler) {
-        syslogClient.addConnectionHandler(handler);
+        getSyslogClient().addConnectionHandler(handler);
     }
 
     /**
@@ -118,14 +119,14 @@ default void addSyslogConnectionListener(Runnable handler) {
      *                disconnected from the web socket
      */
     default void addSyslogDisconnectionListener(Runnable handler) {
-        syslogClient.addDisconnectionHandler(handler);
+        getSyslogClient().addDisconnectionHandler(handler);
     }
 
     /**
      * Removes all existing syslog handlers.
      */
     default void removeAllSyslogListeners() {
-        syslogClient.removeAllHandlers();
+        getSyslogClient().removeAllHandlers();
     }
 
     /**