源代码:
import { of } from 'rxjs';
import { Injectable } from '@angular/core';
import { map } from 'rxjs/operators';
@Injectable()
export class JerrySandBoxService{
name = 'Jerry';
print(){
const observable = of(1, 2, 3);
const opt = map(num => 'hello world: ' + num + ' done');
const newObservable = opt(observable);
newObservable.subscribe(data => console.log(data));
}
}
执行结果:
map操作符接收的是一个箭头函数:
map内部的实现:返回一个新的名为mapOperation的函数,接受单参数。
现在执行opt操作:
source是Observable,project是应用开发人员指定的箭头函数:
Map operator的构造函数:
新建一个Observable对象,将当前Observable对象传给source,operator.project即箭头函数:
对新的Observable对象调用subscribe:
注意这种语法:把this里包含的operator对象赋值给大括号里的operator变量:
sink是subscriber,source是Observable,operator是箭头函数:
如果有operator,先执行箭头函数:
把箭头函数返回的结果,作为新的输入参数,传入到subscriber的next方法里:
最终执行调用subscribe时传入的箭头函数:
要获取更多Jerry的原创文章,请关注公众号"汪子熙":