was working on that sync problem in ASAPhub

Author: thsc42

src/net/sharksystem/asap/utils/ASAPSerialization.java

@@ -173,6 +173,9 @@ public static String printBitsToString(long l, int bits) {
     public static String printByteArrayToString(byte[] byteArray) {
         StringBuilder sb = new StringBuilder();
         for(int index = byteArray.length - 1; index >= 0; index--) {
+            sb.append("[");
+            sb.append(index);
+            sb.append("]: ");
             sb.append(printByteToString(byteArray[index]));
         }
         return sb.toString();

src/net/sharksystem/streams/StreamPairLink.java

@@ -9,6 +9,13 @@ public class StreamPairLink implements StreamPairListener {
     private StreamLink streamLinkB2A;
 
     public StreamPairLink(StreamPair pairA, CharSequence idA, StreamPair pairB, CharSequence idB) throws IOException {
+        this(pairA, idA, pairB, idB, true);
+    }
+
+    public StreamPairLink(
+            StreamPair pairA, CharSequence idA,
+            StreamPair pairB, CharSequence idB,
+            boolean autostart) throws IOException {
         String tagA2B = idB + " ==> " + idA;
         this.streamLinkA2B = new StreamLink(pairA.getInputStream(), pairB.getOutputStream(), true, tagA2B);
         String tagB2A = idA + " ==> " + idB;
@@ -18,8 +25,7 @@ public StreamPairLink(StreamPair pairA, CharSequence idA, StreamPair pairB, Char
         pairA.addListener(this);
         pairB.addListener(this);
 
-        this.streamLinkA2B.start();
-        this.streamLinkB2A.start();
+        if(autostart) this.start();
     }
 
     @Override
@@ -28,4 +34,9 @@ public void notifyClosed(StreamPair closedStreamPair, String key) {
         this.streamLinkA2B.close();
         this.streamLinkB2A.close();
     }
+
+    public void start() {
+        this.streamLinkA2B.start();
+        this.streamLinkB2A.start();
+    }
 }