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

Began life as a copy of #1032029