Kann nicht aufhören Observable Intervall

Question

Ich habe gerade über alles, was ich finden kann, versucht und kann nicht scheinen, dieses Intervall zu bekommen, um den Code innerhalb des Abonnements zu tun. Benutze ich das Intervall falsch?

var subject = new Subject(); 
var interval = Observable.interval(this.settings.timing * 1000); 
var subscription = interval 
    .takeUntil(subject) 
    .subscribe(t => { 
    console.log('pushing new item'); 
    this.activeItems[0].contentLeaving = true; 
    setTimeout(()=>{ 
    this.activeItems[0].imageLeaving = true; 
    setTimeout(()=>{ 
     this.activeItems.push(this.activeItems.shift()); 
     setTimeout(()=>{ 
     this.activeItems[1].contentLeaving = false; 
     this.activeItems[1].imageLeaving = false; 
     },510); 
    },510); 
    },510); 
}); 
this.moduleProps.intervals.push(subject); 

In meinem ngOnDestroy

this.moduleProps.intervals.forEach((i)=>{ 
    i.complete(); 
}); 

Aber nachdem dies passiert Ich sehe immer noch die Aussage Konsolprotokoll sagen „neues Element drückt“, als ob es auf meinem Intervall läuft noch ist.

Answer 1

Gemäß dieser Dokumentation (https://www.learnrxjs.io/operators/filtering/takeuntil.html), emittiert TakeUntil, bis das bereitgestellte Observable emittiert. Sie vervollständigen das Observable, ohne etwas zu emittieren. Versuchen Sie, .next() zu Ihrer onDestroy-Methode hinzuzufügen.

this.moduleProps.intervals.forEach((i)=>{ 
    i.next(); // have subject emit 
    i.complete(); 
}); 

Hier ist eine Arbeits zupfen (https://plnkr.co/edit/Zdf8C9d8vHk84uIMYHvH?p=preview)

Answer 2

Versuchen .takeWhile statt .takeUntil, kann es eine boolean verwenden.

private finished = false; // component property 

var interval = Observable.interval(this.settings.timing * 1000); 
var subscription = interval 
    .takeWhile(_ => this.finished) 
    .subscribe(t => { 
    ... 

OnDestroy ist dann einfach this.finished = true;