Class AbstractCommandStream

    • Field Detail

      • currentBuffer

        private byte[] currentBuffer
      • currentPos

        private int currentPos
    • Constructor Detail

      • AbstractCommandStream

        public AbstractCommandStream()
    • Method Detail

      • isClosed

        protected abstract boolean isClosed()
      • canContinue

        protected boolean canContinue()
        Opposite to isClosed().
        Returns:
        true if not closed
      • beforeNextCommand

        protected void beforeNextCommand()
                                  throws java.io.IOException
        Possibly waiting for next command (see nextCommand()) unless the stream is atomically closed (see isClosed() returns true) before this method has returned.
        Throws:
        java.io.IOException - stream error while waiting for notification regarding next test required by forked jvm
      • nextCommand

        protected abstract Command nextCommand()
      • invalidateInternalBuffer

        protected final void invalidateInternalBuffer()
        Returns quietly and immediately.
      • read

        public int read()
                 throws java.io.IOException
        Used by single thread in StreamFeeder class.
        Specified by:
        read in class java.io.InputStream
        Returns:
        Throws:
        java.io.IOException