fix: replace lambda by anonymous classes

Author: RobinPcrd

src/main/java/io/socket/client/Socket.java

@@ -121,12 +121,15 @@ public boolean isActive() {
      * Connects the socket.
      */
     public Socket open() {
-        EventThread.exec(() -> {
-            if (Socket.this.connected || Socket.this.io.isReconnecting()) return;
+        EventThread.exec(new Runnable() {
+            @Override
+            public void run() {
+                if (Socket.this.connected || Socket.this.io.isReconnecting()) return;
 
-            Socket.this.subEvents();
-            Socket.this.io.open(); // ensure open
-            if (Manager.ReadyState.OPEN == Socket.this.io.readyState) Socket.this.onopen();
+                Socket.this.subEvents();
+                Socket.this.io.open(); // ensure open
+                if (Manager.ReadyState.OPEN == Socket.this.io.readyState) Socket.this.onopen();
+            }
         });
         return this;
     }

src/test/java/io/socket/client/Connection.java

@@ -55,33 +55,39 @@ private Process startServerProcess(String script, int port) throws IOException {
     }
 
     private Future<?> startServerOutput(Process process, String serverName, CountDownLatch latch) {
-        return serverService.submit(() -> {
-            BufferedReader reader = new BufferedReader(
-                    new InputStreamReader(process.getInputStream()));
-            String line;
-            try {
-                line = reader.readLine();
-                latch.countDown();
-                do {
-                    logger.fine(serverName + " SERVER OUT: " + line);
-                } while ((line = reader.readLine()) != null);
-            } catch (IOException e) {
-                logger.warning(e.getMessage());
+        return serverService.submit(new Runnable() {
+            @Override
+            public void run() {
+                BufferedReader reader = new BufferedReader(
+                        new InputStreamReader(process.getInputStream()));
+                String line;
+                try {
+                    line = reader.readLine();
+                    latch.countDown();
+                    do {
+                        logger.fine(serverName + " SERVER OUT: " + line);
+                    } while ((line = reader.readLine()) != null);
+                } catch (IOException e) {
+                    logger.warning(e.getMessage());
+                }
             }
         });
     }
 
     private Future<?> startServerError(Process process, String serverName) {
-        return serverService.submit(() -> {
-            BufferedReader reader = new BufferedReader(
-                    new InputStreamReader(process.getErrorStream()));
-            String line;
-            try {
-                while ((line = reader.readLine()) != null) {
-                    logger.fine(serverName + " SERVER ERR: " + line);
+        return serverService.submit(new Runnable() {
+            @Override
+            public void run() {
+                BufferedReader reader = new BufferedReader(
+                        new InputStreamReader(process.getErrorStream()));
+                String line;
+                try {
+                    while ((line = reader.readLine()) != null) {
+                        logger.fine(serverName + " SERVER ERR: " + line);
+                    }
+                } catch (IOException e) {
+                    logger.warning(e.getMessage());
                 }
-            } catch (IOException e) {
-                logger.warning(e.getMessage());
             }
         });
     }