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();

   }

 }