@ngrx DBのコレクションに個々のアイテムを保存するには

Question

検索が完了したときにトリガーされる次の@ngrxエフェクトがあります。 SEARCH_COMPLETEイベントはコレクションの製品を出力します。

コレクション内の各製品を、単一の値としてコレクション全体ではなく、IndexedDBに保存します。これを達成するために、@ngrx DBを使用する製品から新しいObservableを作成しました。私はlasoがそれを動作させるためにsubscribeコールを使用しなければならなかった。

私の質問は、これは正しい方法ですか？またはsubscribeメソッドを使用しないと良い方法ですか？

@Effect() 
addProductsToDB$: Observable<Action> = this.actions$ 
    .ofType(ProductsSearchActions.ActionTypes.SEARCH_COMPLETE) 
    .map((action: ProductsSearchActions.SearchCompleteAction) => action.payload) 
    .switchMap(products => { 
     return Observable.from(products as IProduct[]) 
      .do(product => { 
       this.db.insert('products', [{ product }]) 
        .subscribe(); 
      }) 
      .map(() => new ProductDBActions.ProductAddedSuccessAction(true)); 
    }); 

Answer 1

「Observable.from（IProductなどの製品[]）を行うため