})
其他创建方法, of, from, fromEvent, fromPromise, interval, range 等API
订阅 subscribe()
当可观察者未被订阅时,将不会被执行
observable.subscribe...(observer);
订阅 Subscription
提供清理数据,取消Observable执行, 取消订阅
const subscription = observable.subscribe(data...observable = Observable.from([1, 2]);
subject.subscribe(data =>{
console.log(data)
})
// 执行订阅
observable.subscribe...mergeMapTo('str') // 拍平数据
.subscribe(num => console.log(num));
// print
str ---- str ---- str
pluck;取出指定属性值...,下游将无法正常发送数据.
concat 合并多个不同的流,按先后顺序输出
const a$ = range(0, 3)
const b$ = range(10, 3)
a$.contact(b$).