Как использовать subscribe-next Rx JS в Angular? - PullRequest
0 голосов
/ 27 мая 2020

Я изучаю rx js. У меня есть наблюдаемое из массива. Я хочу добавить фрукта в функцию, используя subscribe и next. Я написал, но не прав, могу ли я вам помочь. Большое вам спасибо!

const fruits = from([
    "apple",
    "banana",
    "cherry"]);

fruits.subscribe(fruit => this.next(fruit));

1 Ответ

2 голосов
/ 27 мая 2020
const myObserver = {
  next: (item) => console.log('next: ', item),
  error: (err) => console.log('err: ', err),
  complete: () => console.log("Observable completed")
};

of([
  "apple",
  "banana",
  "cherry"
]).subscribe(myObserver);

setTimeout(() => myObserver.next(["Apple"]) ,2000);

Ответ на Ваше упражнение: D

fruits.subscribe(fruit => toConveyorBelt(fruit));
...