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));