[baltimore]

I'm not sure about the type of input stream you are using. If you are using ByteArrayInputStream, every time you are about to read find out the number of bytes available for read without blocking using the available() method.