RxJS中的概念梳理：【原创内容，转载请注明出处】

我们可以把一切输入都当做数据流来处理，比【版权所有，侵权必究】【本文受版权保护】如说：

• 用户操作【版权所有，侵权必究】
【未经授权禁止转载】【未经授权禁止转载】【版权所有】唐霜 www.tangshuang.net
• 网络响应本文版权归作者所有，未经授权不得转载。
【关注微信公众号：wwwtangshuangnet】【版权所有】唐霜 www.tangshuang.net【版权所有，侵权必究】原创内容，盗版必究。未经授权，禁止复制转载。
• 定时器原创内容，盗版必究。
【本文受版权保护】著作权归作者所有，禁止商业用途转载。【作者：唐霜】著作权归作者所有，禁止商业用途转载。转载请注明出处：www.tangshuang.net
• Worker转载请注明出处：www.tangshuang.net
【作者：唐霜】转载请注明出处：www.tangshuang.net著作权归作者所有，禁止商业用途转载。转载请注明出处：www.tangshuang.net著作权归作者所有，禁止商业用途转载。

RxJS提供了各种API来创建数据流：【转载请注明来源】

• 单值：of, empty, never转载请注明出处：www.tangshuang.net
原创内容，盗版必究。【版权所有】唐霜 www.tangshuang.net【本文首发于唐霜的博客】【关注微信公众号：wwwtangshuangnet】【原创内容，转载请注明出处】
• 多值：from【访问 www.tangshuang.net 获取更多精彩内容】
转载请注明出处：www.tangshuang.net著作权归作者所有，禁止商业用途转载。【作者：唐霜】
• 定时：interval, timer【版权所有】唐霜 www.tangshuang.net
【原创内容，转载请注明出处】【版权所有】唐霜 www.tangshuang.net未经授权，禁止复制转载。本文作者：唐霜，转载请注明出处。【版权所有，侵权必究】
• 从事件创建：fromEvent【原创不易，请尊重版权】
【原创不易，请尊重版权】【本文受版权保护】【作者：唐霜】原创内容，盗版必究。
• 从Promise创建：fromPromi【版权所有】唐霜 www.tangshuang.net【访问 www.tangshuang.net 获取更多精彩内容】se
著作权归作者所有，禁止商业用途转载。【本文受版权保护】未经授权，禁止复制转载。
• 自定义创建：create【本文首发于唐霜的博客】
本文作者：唐霜，转载请注明出处。【未经授权禁止转载】【作者：唐霜】本文作者：唐霜，转载请注明出处。

创建出来的数据流是一种可观察的序列，可以本文作者：唐霜，转载请注明出处。本文作者：唐霜，转载请注明出处。被订阅，也可以被用来做一些转换操作，比如著作权归作者所有，禁止商业用途转载。原创内容，盗版必究。：

• 改变数据形态：map, mapTo, p未经授权，禁止复制转载。本文作者：唐霜，转载请注明出处。luck
本文版权归作者所有，未经授权不得转载。【关注微信公众号：wwwtangshuangnet】【原创不易，请尊重版权】
• 过滤一些值：filter, skip, 【转载请注明来源】【原创内容，转载请注明出处】first, last, take
著作权归作者所有，禁止商业用途转载。【作者：唐霜】【访问 www.tangshuang.net 获取更多精彩内容】
• 时间轴上的操作：delay, timeo【关注微信公众号：wwwtangshuangnet】本文版权归作者所有，未经授权不得转载。ut, throttle, deboun著作权归作者所有，禁止商业用途转载。【未经授权禁止转载】ce, audit, bufferTim【关注微信公众号：wwwtangshuangnet】【本文受版权保护】e
【访问 www.tangshuang.net 获取更多精彩内容】本文版权归作者所有，未经授权不得转载。【原创不易，请尊重版权】【未经授权禁止转载】未经授权，禁止复制转载。
• 累加：reduce, scan原创内容，盗版必究。
转载请注明出处：www.tangshuang.net【版权所有】唐霜 www.tangshuang.net【未经授权禁止转载】转载请注明出处：www.tangshuang.net
• 异常处理：throw, catch, r本文作者：唐霜，转载请注明出处。著作权归作者所有，禁止商业用途转载。etry, finally
【关注微信公众号：wwwtangshuangnet】【访问 www.tangshuang.net 获取更多精彩内容】著作权归作者所有，禁止商业用途转载。著作权归作者所有，禁止商业用途转载。
• 条件执行：takeUntil, dela【未经授权禁止转载】【本文首发于唐霜的博客】yWhen, retryWhen, su【本文受版权保护】【版权所有】唐霜 www.tangshuang.netbscribeOn, ObserveOn
【原创内容，转载请注明出处】【访问 www.tangshuang.net 获取更多精彩内容】著作权归作者所有，禁止商业用途转载。【本文首发于唐霜的博客】
• 转接：switch【作者：唐霜】
原创内容，盗版必究。本文作者：唐霜，转载请注明出处。【本文受版权保护】【访问 www.tangshuang.net 获取更多精彩内容】

也可以对若干个数据流进行组合：本文作者：唐霜，转载请注明出处。

• concat，保持原来的序列顺序连接两个【转载请注明来源】【版权所有，侵权必究】数据流
【转载请注明来源】【转载请注明来源】本文版权归作者所有，未经授权不得转载。【关注微信公众号：wwwtangshuangnet】【未经授权禁止转载】
• merge，合并序列【本文受版权保护】
【本文首发于唐霜的博客】本文作者：唐霜，转载请注明出处。【版权所有，侵权必究】【关注微信公众号：wwwtangshuangnet】【未经授权禁止转载】
• race，预设条件为其中一个数据流完成【原创内容，转载请注明出处】
【转载请注明来源】【关注微信公众号：wwwtangshuangnet】著作权归作者所有，禁止商业用途转载。
• forkJoin，预设条件为所有数据流都【版权所有】唐霜 www.tangshuang.net【未经授权禁止转载】完成
著作权归作者所有，禁止商业用途转载。原创内容，盗版必究。著作权归作者所有，禁止商业用途转载。原创内容，盗版必究。【原创内容，转载请注明出处】
• zip，取各来源数据流最后一个值合并为对【访问 www.tangshuang.net 获取更多精彩内容】本文版权归作者所有，未经授权不得转载。象
【关注微信公众号：wwwtangshuangnet】【本文受版权保护】本文版权归作者所有，未经授权不得转载。
• combineLatest，取各来源数据著作权归作者所有，禁止商业用途转载。未经授权，禁止复制转载。流最后一个值合并为数组
本文版权归作者所有，未经授权不得转载。原创内容，盗版必究。【本文受版权保护】【版权所有】唐霜 www.tangshuang.net

数据的管道是什么形状的？在RxJS中，存本文版权归作者所有，未经授权不得转载。【本文受版权保护】在这么几种东西：

• Observable 可观察序列，只出不【未经授权禁止转载】著作权归作者所有，禁止商业用途转载。进
【访问 www.tangshuang.net 获取更多精彩内容】【原创不易，请尊重版权】本文版权归作者所有，未经授权不得转载。【转载请注明来源】转载请注明出处：www.tangshuang.net
• Observer 观察者，只进不出【本文首发于唐霜的博客】
【版权所有】唐霜 www.tangshuang.net未经授权，禁止复制转载。【原创不易，请尊重版权】
• Subject 可出可进的可观察序列，可【本文受版权保护】【版权所有】唐霜 www.tangshuang.net作为观察者
  • ReplaySubject 带回放【本文受版权保护】
  【访问 www.tangshuang.net 获取更多精彩内容】转载请注明出处：www.tangshuang.net【本文受版权保护】【原创不易，请尊重版权】未经授权，禁止复制转载。
【版权所有，侵权必究】【关注微信公众号：wwwtangshuangnet】本文版权归作者所有，未经授权不得转载。
• Subscription 订阅关系未经授权，禁止复制转载。
【未经授权禁止转载】【访问 www.tangshuang.net 获取更多精彩内容】【本文受版权保护】【原创内容，转载请注明出处】

前三种东西，根据它们数据进出的可能性，可本文作者：唐霜，转载请注明出处。【关注微信公众号：wwwtangshuangnet】以通俗地理解他们的连接方式，这也就是所谓【作者：唐霜】【未经授权禁止转载】管道的“形状”，一端密闭一端开头，还是两【转载请注明来源】著作权归作者所有，禁止商业用途转载。端开口，都可以用来辅助记忆。