loadStream(abyte0, 0);
if (abyte0.length > 0) { loadStream(abyte0, 0); }    else { done = true; vt.disconnect(); }
   public final void run() {      boolean done = false;      me = Thread.currentThread();      // load the first response screen      try {         loadStream(abyte2, 0);      }      catch (IOException ioef) {         System.out.println(" run() " + ioef.getMessage());      }      while (!done) {         try {            byte[] abyte0 = readIncoming();            loadStream(abyte0, 0);         }         catch (SocketException se) {//            System.out.println("   DataStreamProducer thread interrupted and stopping " + se.getMessage());            System.out.println("   DataStreamProducer thread interrupted and stopping ");            done = true;         }         catch (IOException ioe) {//              System.out.println(ioe.getMessage());           if (me.isInterrupted())              done = true;         }         catch (Exception ex) {           System.out.println(ex.getMessage());           if (me.isInterrupted())              done = true;         }      }    }