Angular 2 - 等待来自服务的数据初始化

Question

有 2 种服务：

• DataService - 从服务器获取数据
• CacheService - 订阅 DataService 并保存映射数据

和组件

• ComponentA - 注入 CacheService 并具有处理缓存数据的 foo 函数

我的问题是 - 当我的 foo 函数被调用时，我如何确保我的 CacheService 处理完数据。

当前解决方案，我有点喜欢，但不确定是否有更好的 Angular 2 方法。使用 Rx.Observables 完成

我的解决方案（代码已简化）：

export class CacheService {
    myData:                IData;
    dataLoadedObservable:  Observable;
    private _emitter:      any;


    constructor(dataService: DataService){
         this.dataLoaded = Observable.create(
            e => {
            _emitter = e;
        });
    }

    private cacheData(){
         this.dataService.loadData().subscribe(data => {
             this.myData = data;
             this._emitter.next('data loaded');
        });
    }
}

组件A

export class ComponentA {
    this.cacheService.dataLoadedObservable.subscribe(
            isLoaded => {
                if(isLoaded === 'data loaded'){
                    // Now this.cacheService.myData is ready
                }
            }
        );
}

Answer 1

您可能应该像这样重构您的数据服务：

export class CacheService {
    private data$:Observable<IData>;

    constructor(private dataService: DataService){
        //We initialize the data Observable.
        this.data$ = new Subject();
        //We load initial data.
        this.dataService.loadData().subscribe(data => {
            //Once the data is loaded, we have to emit its value from our data$ observable.
            this.data$.next(data);
        });
    }

    //getter for our observable.
    public getData():Observable<IData>{
        return this.data$
    }

    //setter for data, hiding the observable logic behind.
    public setData(data:IData){
        this.data$.next(data);
    }
}

此重构背后的目标是将您的数据隐藏在 observable 后面。

一个简单的用法是：

cacheService.data.subscribe(data => console.log(data));

在您从中发出数据之前不会调用订阅（使用next() 调用），这意味着一旦您实际拥有数据，您的订阅就会被调用。