RXJS我该选用哪个操作符之-创建篇

RXJS该怎么上手?这么多操作符该用哪个?RXJS比较强大,操作符众多,想熟悉需要比较长时间的运用,所以大部分新手都比较疑惑应该使用哪些操作符去实现自己的数据流的操作。

更多详情请翻阅 RXJS中文翻译文档

我该选用哪个操作符? - 创建操作符

使用此页面查找Observable符合您需求的类型创建操作:

静态方法
我想创建一个新的序列 使用自定义逻辑 Observable.create
像一个for循环 Observable.generate
并随时间发射值 Observable.generateWithRelativeTime
Observable.generateWithAbsoluteTime
它返回一个值 Observable.return/just
多次 Observable.repeat
这会抛出错误 Observable.throw
完成了 Observable.empty
从来没有做任何事情 Observable.never
从事件 Observable.fromEvent
它使用自定义函数来添加和删除事件处理程序 Observable.fromEventPattern
来自一个ES6 Promise Observable.fromPromise
它可迭代 覆盖到数组中的值 Observable.fromArray
对象键/值对 Observable.pairs
异步元素 Observable.for
数值范围内的值 Observable.range
来自一个可迭代的数组或类似数组的对象的值 Observable.from
来自参数 Observable.of
根据定时器发出值 Observable.interval
具有可选的初始延迟 Observable.timer
不传参调用函数 在特定的调度程序 Observable.start
异步 Observable.startAsync
取决于订阅时 基于布尔条件 Observable.if
f从一组预先设定的序列 Observable.case
使用自定义逻辑 Observable.defer
它取决于资源 Observable.using
我想包装一个函数 并产生一个序列的结果 Observable.toAsync
它接受回调 Observable.fromCallback
它接受Node.js回调 Observable.fromNodeCallback
我想结合多个序列 并且仅从产生值的序列中接收值 Observable.amb
所有人都已经完成通知 Observable.forkJoin
并输出所有这些值 Observable.merge
为了 不改变时重复使用最新值 Observable.combineLatest
每个值只使用一次 Observable.zip
通过订阅每个序列为了 当前一个序列完成时 Observable.concat
当另一个序列抛出错误时 Observable.catch
不管先前的序列是完成还是抛出错误 Observable.onErrorResumeNext
通过响应不同的值组合(连接微积分) Observable.when
0%