From c12bf89e8f3cb342ae3ac8881dab0e41fe24b033 Mon Sep 17 00:00:00 2001
From: DmitriyMX <dimon550@gmail.com>
Date: Mon, 17 Jul 2017 03:20:39 +0300
Subject: [PATCH] =?UTF-8?q?Zond:fix:=20=D0=BE=D1=88=D0=B8=D0=B1=D0=BA?=
 =?UTF-8?q?=D0=B0=20=D0=B7=D0=B0=D0=BF=D0=B8=D1=81=D0=B8=20=D0=B2=20"?=
 =?UTF-8?q?=D1=82=D1=80=D1=83=D0=B1=D1=83"?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 zond/src/main/java/asys/zond/PipeInputStream.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/zond/src/main/java/asys/zond/PipeInputStream.java b/zond/src/main/java/asys/zond/PipeInputStream.java
index ff44a07..f09bfdc 100644
--- a/zond/src/main/java/asys/zond/PipeInputStream.java
+++ b/zond/src/main/java/asys/zond/PipeInputStream.java
@@ -24,9 +24,12 @@ public class PipeInputStream extends InputStream {
             }
         }
 
-        if ((lastWritePos + strBytes.length) >= 1024) {
+        if ((lastWritePos + strBytes.length) >= buffer.length) {
             wallPos = lastWritePos;
             lastWritePos = 0;
+            if (lastReadPos == wallPos) {
+                lastReadPos = 0;
+            }
         }
 
         System.arraycopy(strBytes, 0, this.buffer, lastWritePos, strBytes.length);