code: private void readStreamResult(InH3 hIn, HeadersAmp headers)
      throws IOException
    {
      ServiceRefAmp serviceRef = readToAddress(hIn);
      
      long id = hIn.readLong();
  
      QueryRefAmp queryRef = serviceRef.getQueryRef(id);
  
      if (queryRef != null) {
        ClassLoader loader = queryRef.getClassLoader();
  
        Thread thread = Thread.currentThread();
        thread.setContextClassLoader(loader);
        
        // XXX: _serializer.setClassLoader(loader);
      }
      
      int sequence = hIn.readInt();
      List<Object> values = (List) hIn.readObject();
      Throwable exn = (Throwable) hIn.readObject(Throwable.class);
      boolean isComplete = hIn.readBoolean();
      
      if (log.isLoggable(_logLevel)) {
        log.log(_logLevel, "stream-result-r " + values + "," + isComplete + " (in " + this + ")"
                 + "\n  {id:" + id + ", to:" + serviceRef + "," + headers + "}");
      }
      
      if (queryRef != null) {
        if (queryRef.accept(headers, values, sequence, isComplete)) {
          serviceRef.removeQueryRef(id);
        }
        
        if (exn != null) {
          serviceRef.removeQueryRef(id);
          queryRef.fail(headers, exn);
        }
  
        /*
        if (isComplete) {
          // XXX: timing
          //serviceRef.removeQueryRef(id);
          
          // queryRef.completeStream(headers, sequence);
        }
        */
        /*
        else if (queryRef.isCancelled()) {
          
          System.out.println("CANCEL_ME: " + queryRef);
        }
        */
      }
      else if (log.isLoggable(Level.WARNING)) {
        log.warning("query-result qid=" + id + " for service " + serviceRef +
                   " does not match any known queries.\n" + headers);
      }
    }
docs: The stream result message is a partial or final result from the target's
  stream.