network connector to reconnect on proxy timeout

java_console/io/src/main/java/com/rusefi/io/ByteReader.java

@@ -20,7 +20,7 @@ public interface ByteReader {
 
     Logging log = getLogging(ByteReader.class);
 
-    static void runReaderLoop(String loggingPrefix, DataListener listener, ByteReader reader, TcpIoStream.DisconnectListener disconnectListener, AbstractIoStream ioStream) {
+    static void runReaderLoop(String loggingPrefix, DataListener listener, ByteReader reader, AbstractIoStream ioStream) {
         /**
          * Threading of the whole input/output does not look healthy at all!
          *
@@ -40,7 +40,7 @@ public interface ByteReader {
                     listener.onDataArrived(Arrays.copyOf(inputBuffer, result));
                 } catch (IOException e) {
                     log.error("TcpIoStream: End of connection " + e);
-                    disconnectListener.onDisconnect();
+                    ioStream.close();
                     return;
                 }
             }

java_console/io/src/main/java/com/rusefi/io/tcp/TcpIoStream.java

@@ -53,6 +53,7 @@ public class TcpIoStream extends AbstractIoStream {
     public void close() {
         super.close();
         FileUtil.close(socket);
+        disconnectListener.onDisconnect();
     }
 
     @Override
@@ -78,7 +79,7 @@ public class TcpIoStream extends AbstractIoStream {
 
     @Override
     public void setInputListener(final DataListener listener) {
-        ByteReader.runReaderLoop(loggingPrefix, listener, input::read, disconnectListener, this);
+        ByteReader.runReaderLoop(loggingPrefix, listener, input::read, this);
     }
 
     public interface DisconnectListener {

java_console/io/src/main/java/com/rusefi/proxy/BaseBroadcastingThread.java

@@ -59,6 +59,7 @@ public class BaseBroadcastingThread {
                 }
             } catch (IOException e) {
                 log.error("exiting thread " + e);
+                stream.close();
             }
         });
     }