package org.paneris.bibliomania.fti;
   
   class OrTextSearchResults extends TextSearchResultsBase {
     private TextSearchResults[] streams;
     private TextSearchResults currentStream = null;
     private int hitWordsCount;
   
     public OrTextSearchResults(TextSearchResults[] streams) {
       this.streams = streams;
      hitWordsCount = 0;
      for (int i = 0; i < streams.length; ++i)
        hitWordsCount = Math.max(hitWordsCount, streams[i].hitWordsCount());
    }
  
    public int hitWordsCount() {
      return hitWordsCount;
    }
  
    public void init() {
      // FIXME sort streams by local count, but into a copied array
      for (int w = 0; w < streams.length; ++w)
        streams[w].init();
      findHit();
    }
  
    private void findHit() {
      int firstIndex = Integer.MAX_VALUE;
      currentStream = null;
      for (int w = 0; w < streams.length; ++w) {
        TextSearchResults stream = streams[w];
        int streamIndex = stream.currentWordIndex();
        if (streamIndex != -1 && streamIndex < firstIndex) {
          firstIndex = streamIndex;
          currentStream = stream;
        }
      }
    }
  
    public void skipToNextHit() {
      if (currentStream != null) {
        currentStream.skipToNextHit();
        findHit();
      }
    }
  
    public int currentWordIndex() {
      return currentStream == null ? -1 : currentStream.currentWordIndex();
    }
  
    public int currentOffset() {
      return currentStream == null ? -1 : currentStream.currentOffset();
    }
  
    public void close() {
      for (int i = 0; i < streams.length; ++i)
        streams[i].close();
    }
  }