public Justification[] nextChunk(){
  if (!hasNext()) {
    throw new NoSuchElementException();
  }
  if (ft != null) {
    awaitReader();
  }
  final int n=buffer.size();
  final Justification[] stmts=new Justification[n];
  for (int i=0; i < n; i++) {
    stmts[i]=next();
  }
  if (log.isDebugEnabled())   log.debug("chunkSize=" + n + ", nchunks="+ nchunks+ ", #read(caller)="+ numReadByCaller+ ", #read(src)="+ numBuffered);
  return stmts;
}

public Justification [ ] nextChunk ( ) { if ( ! hasNext ( ) ) { throw new NoSuchElementException ( ) ; } if ( ft != null ) { awaitReader ( ) ; } final int n = buffer . size ( ) ; final Justification [ ] stmts = new Justification [ n ] ; for ( int i = 0 ; i < n ; i ++ ) { stmts [ i ] = next ( ) ; } if ( log . isDebugEnabled ( ) ) log . debug ( "chunkSize=" + n + ", nchunks=" + nchunks + ", #read(caller)=" + numReadByCaller + ", #read(src)=" + numBuffered ) ; return stmts ; }
returns a chunk whose size is the # of statements currently in the buffer . < p > note : when asynchronous reads are used , the buffer will be transparently refilled and should be ready for a next chunk by the time you are done with this one .
