// always keeps a dynamically updated list of the n most probable

// results

// for maxResults default, see SetOfMostProbable

// not synchronized

srecord noeq PSCollectMostProbable<A>(

  IVF1<IVF1<WithProbability<A>>> action) implements IF0<Set<WithProbability<A>>>, Steppable {

  new ProbabilisticScheduler ps;

  new SetOfMostProbable<A> results;

  bool verbose;

  *() {}

  *(int maxResults) {

    setMaxResults(maxResults);

  }

  *(int maxResults,

    ProbabilisticScheduler *ps,

    IVF1<IVF1<WithProbability<A>>> *action) {

      setMaxResults(maxResults);

    }

  *(int maxResults, IVF2<IProbabilisticScheduler, IVF1<WithProbability<A>>> action) {

    setMaxResults(maxResults);

    this.action = out -> action.get(ps, out);

  }

  void add(WithProbability<A> result) {

    results.add(result);

  }

  selfType run() {

    action?.get(result -> add(result));

    this;

  }

  void setMaxResults(int maxResults) {

    results.setMaxSize(maxResults);

  }

  selfType verbose(bool verbose) { this.verbose = verbose; this; }

  // results sorted by probability. instant

  public Set<WithProbability<A>> results aka get() {

    ret results;

  }

  public bool step() { ret ps.step(); }

}