私はサービスと、それを使用するコンポーネントを持っています。私はBehaviorSubject
を介して配列の変更を通知し、両方とも購読しています。ObjectUnsubscribedErrorは二回
PagesService
は、bootstrap
で提供され、インスタンスを1つだけ共有することができます。それは、必要なときにいつでもページをダウンロードするのではなく、配列を保持する必要があるからです。これは、両方の、細かい初めての作品
pages.service.ts
import { Injectable } from '@angular/core';
import { BehaviorSubject } from 'rxjs/Rx';
import { Http, Response } from '@angular/http';
import { Page } from './../models/page';
@Injectable() export class PagesService {
public pages$: BehaviorSubject<Page[]> = new BehaviorSubject<Page[]>([]);
private pages: Page[] = [];
constructor(private http: Http) { }
getPagesListener() {
return this.pages$;
}
getAll() {
this.http.get('/mockups/pages.json').map((res: Response) => res.json()).subscribe(
res => { this.resetPagesFromJson(res); },
err => { console.log('Pages could not be fetched'); }
);
}
private resetPagesFromJson(pagesArr: Array<any>) {
// Parses de Array<any> and creates an Array<Page>
this.pages$.next(this.pages);
}
}
pages_list.component.ts
import { Component, OnInit } from '@angular/core';
import { Router } from '@angular/router-deprecated';
import { BehaviorSubject } from 'rxjs/Rx';
import { PagesService } from '../../shared/services/pages.service';
import { GoPage } from '../../shared/models/page';
@Component({
moduleId: module.id,
selector: 'go-pages-list',
templateUrl: 'pages_list.component.html',
styleUrls: ['pages_list.component.css']
})
export class PagesListComponent implements OnInit {
pages$: BehaviorSubject<GoPage[]>;
pages: GoPage[];
constructor(private pagesService: PagesService, private router: Router) { }
ngOnInit() {
this.pages$ = this.pagesService.getPagesListener();
this.pages$.subscribe((pages) => { this.pages = pages; console.log(pages) });
this.pagesService.getAll();
}
ngOnDestroy() {
this.pages$.unsubscribe();
}
}
:
コードは以下のとおりです。サブスクリプションonInitとサブスクライブ解除onDestroy。しかし、私がリストに戻って再び購読しようとすると(ページ[]の現在の値を取り出して将来の変更を聞くために)、はエラーEXCEPTION: ObjectUnsubscribedError
を発生させます。
私が購読を停止した場合、リストに入るたびに、新しい購読が積み重ねられ、next()が受信されるとすべてが中止されます。
なぜ注射された被験者のリファレンスに直接加入していないのですか? –