Observable interval을 멈출 수 없다

Question

나는 내가 찾을 수있는 모든 것에 대해 시도해 보았고,이 구간을 구독 내부에서 코드하는 것을 멈추는 것처럼 보이지는 않는다. 간격을 잘못 사용하고 있습니까? 에서

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); 

내

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

그러나 ngOnDestroy이 난 아직도 콘솔 로그 문은 여전히 ​​내 간격에서 실행중인 것처럼 "새 항목을 밀어"라고 볼 일 후.

Answer 1

이 설명서 (https://www.learnrxjs.io/operators/filtering/takeuntil.html)에 따라 takeUntil은 제공된 관찰 가능 항목이 방출 될 때까지 방출됩니다. 당신은 아무것도 방출하지 않고 관측을 완료하고 있습니다. onDestroy 메소드에 .next()를 추가하십시오. 여기

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

이 작업 쿵하는 소리입니다 ( https://plnkr.co/edit/Zdf8C9d8vHk84uIMYHvH?p=preview)

Answer 2

는 .takeWhile 대신 .takeUntil, 그것은 부울를 사용하십시오.

private finished = false; // component property 

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

들의 OnDestroy는`단순히 this.finished = true;