rx的初步使用教程(2)

import { Observable } from 'rxjs'; export default { domStreams: ['getInput$'], subscriptions () { return { value$: this.getInput$ // 选取e.event.target.value .pluck('event', 'target', 'value') .debounceTime(2000) // 根据value值作比较，如果和上一次一样则不发出值 .distinctUntilChanged() .map(val => { console.log(val); return val; }) } } }