手册

基础的 Rx 使用非常直观。

转换成 Observable

使用构造操作符能够轻松创造出一个 Observable 对象。

// 来自可枚举列表
Rx.Observable.of('foo','bar')

// 来自数组
Rx.Observable.from([1,2,3])

// 来自事件
Rx.Observable.fromEvent(#btn, 'click')

// 来自 Promise
Rx.Observable.fromPromise($http.get('/abc.do'))

// 来自标准回调
let observableExist = Rx.Observable.bindCallback(fs.exist);
observableExist('file.txt').subscribe(existed=>console.log('File existed? ", existed))

// 来自Nodejs回调
let observableRename = Rx.Observable.bindNodeCallback(fs.rename)
observableRename('file.text', 'file2.text').subscribe(()=>console.log('Rename success'))

创建 Observable

除了从其他事件中转换，手动创建也未尝不可。

let ob = new Rx.Subject();
ob.subscribe(value=>console.log('Value: '+value))

// 外部填充事件
ob.next('Hello fuchao')

let ob = Rx.Observable.create(ob=>{
    // 内部填充数据流
    ob.next('hello')
    ob.next('fuchao')
})

ob.subscribe(value=>console.log(value))

控制数据流动

let input = Rx.Observable.fromEvent(#input, 'input')

input.filter(event=>event.target.value > 2)
    .map(event=>event.target.value)
    .subscribe(value=>console.log(value))
    
    
input.delay(200)
    .map(event=>event.target.value)
    .subscribe(value=>console.log(value))
    
input.throttleTime(200)
    .map(event=>event.target.value)
    .subscribe(value=>console.log(value))
    
input.debounceTime(200)
    .map(event=>event.target.value)
    .subscribe(value=>console.log(value))
    
input.take(3）
    .map(event=>event.taget.value)
    .subscribe(value=>console.log(value))
    
let stop = Rx.Observable.fromEvent(#btn, 'click')

input.takeUnitl(stop)
    .map(event=>event.target.value)
    .subscribe(value=>console.log(value))

输出值

let input = Rx.Observable.fromEvent(#input, 'input')

input.map(event=>event.target.value)
    .subscribe(value=>console.log(value))
    
input.pluck('target', 'value')
    .subscribe(value=>console.log(value))

input.pluck('target', 'value').pairwise()
    .subscribe(value=>console.log(value))

input.pluck('target', 'value').distinct()
    .subscribe(value=>console.log(value))

input.pluck('target', 'value').distinctUntilChanged()
    .subscribe(value=>console.log(value))