The GatsInputStream is much, much simpler, should be much faster, and works

more like java says blocking things should work.  If you ask it to read an
object, it will, it will wait on the socket until it gets a whole one, or throws
an exception.

1 files changed, 20 insertions, 0 deletions

diff --git a/java/com/xagasoft/gats/GatsInputStream.java b/java/com/xagasoft/gats/GatsInputStream.java
index 8eac738..5cd830d 100644
--- a/java/com/xagasoft/gats/GatsInputStream.java
+++ b/java/com/xagasoft/gats/GatsInputStream.java
@@ -21,6 +21,25 @@ public class GatsInputStream
         {
                 do
                 {
+                        iVer = is.read();
+                } while( iVer == 0 );
+
+                switch( iVer )
+                {
+                        case 1:
+                                DataInputStream dis = new DataInputStream( is );
+                                iSize = dis.readInt();
+                                return GatsObject.read( is );
+                }
+
+                return null;
+        }
+
+                /*
+        public GatsObject readObject() throws java.io.IOException
+        {
+                do
+                {
                         if( baos.size() < 5 )
                         {
                                 byte aBuf[] = new byte[5-baos.size()];
@@ -97,5 +116,6 @@ public class GatsInputStream
                 baos.reset();
                 return true;
         }
+        */
 };