rxjs里的Observable对象和map配合的一个用法

源代码：

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的原创文章，请关注公众号"汪子熙":