測試代碼：

import { of } from 'rxjs'; import { Injectable } from '@angular/core';@Injectable() export class JerrySandBoxService{name = 'Jerry';print(){const myObservable = of(1, 2, 3);// 創建一個觀察者對象-Observer(處理next、error、complete回調)const myObserver = {next: x => console.log('Observer got a next value: ' + x),error: err => console.error('Observer got an error: ' + err),complete: () => console.log('Observer got a complete notification'),};// 通過Observable的subscribe函數，觀察者去訂閱可觀察者的消息myObservable.subscribe(myObserver);} }

調用Observable構造器，傳入的數組被subscribeToArray再包裝一層：

Observable的構造函數，接受的參數是另一個函數：

最后of返回的是一個observable對象。

要獲取更多Jerry的原創文章，請關注公眾號"汪子熙":

總結

以上是生活随笔為你收集整理的rxjs里的Observable对象如何消费的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。