rxjs里的Observable对象如何消费

测试代码：

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对象如何消费相关推荐

rxjs里的Observable对象和map配合的一个用法
源代码: import { of } from 'rxjs'; import { Injectable } from '@angular/core'; import { map } from 'rxj ...
通过一个最简单的例子，理解Angular rxjs里的Observable对象的pipe方法
源代码: import { of } from 'rxjs'; import { Injectable } from '@angular/core'; import { map } from 'rxj ...
rxjs里的Observable对象subscribe方法的执行原理
看个例子: const myObservable = of(1, 2, 3);// 创建一个观察者对象-Observer(处理next.error.complete回调)const myObserve ...
rxjs of操作符生成的Observable对象的执行详细分析
代码: const a = of([1, 2, 3]); a.subscribe((data) => console.log('Fairy:' + data)); 单步调试,首先执行of所在的i ...
如何在Chrome调试器里检查嵌套Observable对象
一个例子: 举个例子,看如下这个嵌套的Observable对象: items$: Observable<Observable<Product>[]> = this.compon ...
从调试器里观察到的Observable对象反推出其赋值的源代码位置
展开Observable对象,从其operator能观察到施加在该Observable对象上的操作: Map操作:(event) => this.getBreakpoint(event.targ ...
Rxjs 里 subscribeToArray 工具函数的详细分析
subscribeToArray 函数体的逻辑:它的实质是一个函数: 该函数接收一个 array 作为输入参数,遍历这个 array,将其每个元素,作为另一个匿名函数执行的一部分.该匿名函数体内,将 ...
rxjs里switchMap operators的用法
switchMap相关文章 rxjs里switchMap operators的用法通过rxjs的一个例子, 来学习SwitchMap的使用方法 rxjs switchMap的实现原理 rxjs的ma ...
你会用RxJS吗？【初识 RxJS中的Observable和Observer】
概念 RxJS是一个库,可以使用可观察队列来编写异步和基于事件的程序的库. RxJS 中管理和解决异步事件的几个关键点: Observable: 表示未来值或事件的可调用集合的概念. Observer ...

rxjs里的Observable对象如何消费

rxjs里的Observable对象如何消费相关推荐

最新文章

热门文章