Temporarily disabled the fix for 15234

Signed-off-by: Artem Ananev <[email protected]>
hashgraph · Sep 13, 2024 · 8510ead · 8510ead
1 parent 37c0842
commit 8510ead
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...mon/src/main/java/com/swirlds/common/merkle/synchronization/streams/AsyncInputStream.java b/...mon/src/main/java/com/swirlds/common/merkle/synchronization/streams/AsyncInputStream.java
@@ -148,15 +148,15 @@ private void run() {
         logger.info(RECONNECT.getMarker(), this.toString() + " start run()");
         try {
             while (!Thread.currentThread().isInterrupted()) {
-                final int viewId = readInt();
+                final int viewId = inputStream.readInt();
                 if (viewId < 0) {
                     logger.info(RECONNECT.getMarker(), "Async input stream is done");
                     alive.set(false);
                     break;
                 }
-                final int len = readInt();
+                final int len = inputStream.readInt();
                 final byte[] messageBytes = new byte[len];
-                readBytes(messageBytes);
+                inputStream.readNBytes(messageBytes, 0, len);
 
                 if (useSharedQueue.contains(viewId)) {
                     assert !viewQueues.containsKey(viewId);