Почему последний вызов выполняется 3 раза?

Question

У меня есть этот кусок кода, который вызывается из компонента:

choose(n?: number): Observable<PickQuality[]> { 
    var chosenObserver: Observer<PickQuality[]>; 
    alert(n); // <-- Notice this line 

    this.getOptions().subscribe(options => { 
      alert(n); // <-- And this one 
      this.reevaluate(); 

      var sorted = options.sort((a, b) => b.score - a.score); 
      var chosen: PickQuality[]; 

      if(n) chosen = sorted.slice(0, n); 
      else chosen = sorted.slice(0, 1); 

      chosenObserver.next(chosen); 
    }); 

    let obs = new Observable<PickQuality[]>(observer => chosenObserver = observer); 
    return obs; 
} 

Вызов следующее:

test.choose().subscribe(a => console.log(a)); 
    test.choose(5).subscribe(b => console.log(b)); 
    test.choose(15).subscribe(c => console.log(c)); 

1-ый вызов, чтобы предупредить печать должным образом («не определено», «5» , «15»), но второй печатает «15» 3 раза. Почему это происходит? Он работал нормально, но некоторые изменения, которые я сделал (и не смог отслеживать), изменили это, и я не могу его исправить.

Answer 1

Я угадываю здесь, но я думаю, что вы хотите делиться подписками через share().

Когда число наблюдателей, подписавшихся на опубликованные наблюдаемые, идет от 0 до 1, мы подключаемся к лежащей ниже наблюдаемой последовательности.

При добавлении второго абонента дополнительные дополнительные подписки не добавляются в базовую наблюдаемую последовательность . В результате операции, которые приводят к побочным эффектам , не повторяются для каждого абонента.

constructor() { 
    this.observable = ....share() 
} 

getOptions() { 
    return this.observable; 
}