Я пишу настольное приложение с использованием углового2 и электрона, и есть функция загрузки.Angular2 - Rxjs Subject запускается дважды даже после отмены подписки
Мои DownloadService
это
import {Injectable} from '@angular/core';
import {Subject} from "rxjs";
interface IQueueItem {
url: string
}
@Injectable()
export class DownloadService {
private queue: Array<IQueueItem> = [];
private downloadSubject: Subject<any>;
constructor() {
this.downloadSubject = new Subject();
}
addToList(item: IQueueItem) {
this.queue.unshift(item);
downloadList();
return this.downloadSubject;
}
downloadList() {
// pick one item from queue and send it to electron to download and store
// do this every time a chunk of data received
this.downloadSubject.next(evt);
...
}
pauseDownload(item) {
// send an event to electron to it should stop downloading and therefore no chunk of data will receive
// also remove item from queue
...
}
}
И мой ItemComponent
это:
import {Component} from '@angular/core';
import {DownloadService} from "../services/download.service";
@Component({
selector: 'app-item',
template: `
...
`
})
export class ItemComponent {
constructor(private downloadService: DownloadService) {
this.addToQueue();
}
subscription;
downloadedBytes = 0;
fileUrl = '';
pause() {
this.downloadService.pauseDownload(this.fileUrl);
this.subscription.unsubscribe();
...
}
resume() {
this.addToQueue();
}
private addToQueue() {
this.subscription = this.downloadService.addToList(this.fileUrl)
.subscribe(evt => {
console.log(evt.delta);
this.downloadedBytes += evt.delta;
});
}
}
Проблема заключается в том, когда я Приостановка деталь я отказаться от подписки Subject
передается от DownloadService
, но когда я возвращаюсь снова, каждый console.log()
печатает дважды и добавляет дважды данные в downloadedBytes
. Также, если я снова приостанавливаю и возобновляю, он будет добавлять все больше и больше байтов и журналов!
Я искал, но не нашел подсказки для решения.
Я предполагаю, что это происходит от того, что downloadList() добавляет компонент в список. Но поскольку мы не знаем, для чего этот список, когда субъект испускает события, для чего он используется, что делает pauseCourse() и т. Д., Его трудно объяснить. Предоставьте полный пример, воспроизводящий проблему. –
@JBNizet жаль, что я сделал много упрощения, и, видимо, результат был неудачным. Я добавил дополнительные сведения –
Я не могу воспроизвести его https://plnkr.co/edit/64mn6U1omy8JPE6LD4Nf?p=preview. Проверьте также http://stackoverflow.com/questions/35673582/http-request-made-multiple-times-in-angular2-service – yurzui