Повторить наблюдаемый пока условие не будет выполнено

Question

Вот моя машинописная функция isIndexComplete.

isIndexComplete(index_id:string): Observable<boolean> {
        console.log("Entering get indexer status");
        return this._http.get<IIndexerGetStatus>(`http://${environment.agent_ip}:${environment.agent_port}/`,{
            params:{
                action:'IndexerGetStatus',
                epochTime:'true',
                maxResults:'1',
                responseFormat:'simplejson',
                Index:index_id
            }
        }).pipe(
            map(response => {
                if (response.autnresponse.responsedata.item[0].percentage_processed == '100'){
                    console.log("percentage_processed "+ response.autnresponse.responsedata.item[0].percentage_processed);
                    return true;
                }
                else{
                    console.log("percentage_processed "+ response.autnresponse.responsedata.item[0].percentage_processed);
                    this.currentProgress = response.autnresponse.responsedata.item[0].percentage_processed;
                    this.isIndexComplete(index_id).subscribe();
                    return false
                }
            })
        )
    }

Мне нужно продолжать вызывать isIndexComplete из SaveAgentRecord, пока this.value не станет 100%

SaveAgentRecord(topicText:string, topicTextBoolean:string): void {
    this._agentstore.createAgentEntry(topicText, topicTextBoolean).subscribe( response =>{
        var index_id = this._agentstore.getIndexID(response);
        this._agentstore.isIndexComplete(index_id).subscribe(response => {
            this.AgentRuleCreationProgress = +this._agentstore.currentProgress;
            this.value = this.AgentRuleCreationProgress;
            if(this.value < 100){
                console.log("Value less than 100");
            }
        })
        console.log("Get Index Status shows 100%")
        this.ShowAgentCreated(topicText);
    });
}

Как мне это сделать? Также я не хочу выполнять это. ShowAgentCreated (topicText), пока его 100%

Answer 1

Что-то в этом роде, но замените источник на this._http.get<IIndexerGetStatus> и измените процент в соответствии с . currentProgress свойство

defer(()=>{
  let percentage=0
  return source.pipe(
    tap(_=>percentage++),
    repeatWhen((e) => {
    return timer(2000).pipe(takeWhile(_=>percentage<2))
  }),
)
}).subscribe()