Take не является функцией: Angular 7 |Observable.take выдает ошибку времени выполнения - PullRequest
Новая
       56

Take не является функцией: Angular 7 |Observable.take выдает ошибку времени выполнения

0 голосов
/ 04 декабря 2018

Я создаю корзину для покупок, и я использовал службу корзины для покупок, в которой я назначаю количества для продукта / добавляю продукт в корзину.Есть ли другой способ, кроме как использовать take для получения первого экземпляра наблюдаемого элемента $?

Я правильно импортирую оператор take, но он продолжает выдавать ошибку времени выполнения.Если я не использую take, то назначенное количество будет некоторым случайным целым числом вместо 1.

Я получаю приведенную ниже ошибку при использовании take () для наблюдаемой в следующем коде: 

import { Injectable } from '@angular/core';
import { AngularFireDatabase } from 'angularfire2/database';
import { Product } from '../app/models/product';
import 'rxjs/add/operator/take';//tried this one too
import { take } from 'rxjs-compat/operator/take';

@Injectable({
  providedIn: 'root'
})
export class ShoppingCartService {

  constructor(private db: AngularFireDatabase) { }

  private create() {
    return this.db.list('/shopping-carts').push({
      dateCreated: new Date().getTime()
    });
  }


  private getCart(cartId: string) {
    return this.db.object('/shopping-carts/' + cartId);
  }
  private async getOrCreateCartId() {
    let cartId = localStorage.getItem('cartId');
    if (cartId) return cartId;

    let result = await this.create();
    localStorage.setItem('cartId', result.key);
    return result.key;

  }

  async addToCart(product: Product) { 
    let cartId = await this.getOrCreateCartId();
    let item$ = this.db.object('/shopping-carts/'+cartId+'/items/'+product.$key);
    item$.take(1).subscribe(item=>{
      if(item.$exists()) item$.update({quantity : item.quantity + 1});
      else item$.set({product : product , quantity : 1 });
    });
  }

}




Error: Uncaught (in promise): TypeError: item$.take is not a function. (In 'item$.take(1)', 'item$.take' is undefined) http://localhost:4200/main.js:1581:35 step@http://localhost:4200/main.js:1534:27 fulfilled@http://localhost:4200/main.js:1506:62 onInvoke@http://localhost:4200/vendor.js:46707:39 run@http://localhost:4200/polyfills.js:2483:49 http://localhost:4200/polyfills.js:3217:37 onInvokeTask@http://localhost:4200/vendor.js:46698:43 runTask@http://localhost:4200/polyfills.js:2533:57 drainMicroTaskQueue@http://localhost:4200/polyfills.js:2940:42 invokeTask@http://localhost:4200/polyfills.js:2845:40 invokeTask@http://localhost:4200/polyfills.js:3885:20 globalZoneAwareCallback@http://localhost:4200/polyfills.js:3911:27
resolvePromise — zone.js:814
(anonymous function) — zone.js:724
fulfilled — products.component.ts:11
onInvoke — core.js:14143
run — zone.js:138
(anonymous function) — zone.js:872
onInvokeTask — core.js:14134
runTask — zone.js:188
drainMicroTaskQueue — zone.js:595
invokeTask — zone.js:500
invokeTask — zone.js:1540
globalZoneAwareCallback — zone.js:1566

1 Ответ

0 голосов
/ 04 декабря 2018

2 проблемы, которые я замечаю:

  1. Импорт - должен быть: import { take } from 'rxjs/operators';

  2. Вы должны использовать pipe: в вашем случае:

    item$.pipe(take(1)).subscribe(...)

Подробнее об этом можно узнать на здесь

...