例如 filter:
filter就是按条件过滤, 只让合格的元素通过.
例 debounceTime (恢复时间):
如果该元素后10毫秒内, 没有出现其它元素, 那么该元素就可以通过....作为Observable, 你可以去订阅它, 提供一个Observer就会正常的收到推送的值. 从Observer的角度是无法分辨出这个Observable是单播的还是一个Subject...., 订阅者1通过过滤和映射它只处理keyup类型的事件, 而订阅者2只处理input事件....(500));
// 输出: 0,1,2,3,4,5,6,7,8,9...0,1,2,3,4,5,6,7,8
const subscribe = example.subscribe(val => console.log...多个输入的observable的值, 按顺序, 按索引进行合并, 如果某一个observable在该索引上的值还没有发射值, 那么会等它, 直到所有的输入observables在该索引位置上的值都发射出来