javascript - Rxjs如何重用运算符

Question

我正在使用 Rx，并且有两个使用相同运算符的点击流。如何提取相同的部分并重复使用它？

let gender$ = Rx.Observable.fromEvent(gender, 'click').map(e => e.target).filter(t => t.nodeName === "LI").map(li => li.textContent.trim())

let type$ = Rx.Observable.fromEvent(type, 'click').map(e => e.target).filter(t => t.nodeName === "LI").map(li => li.textContent.trim())

let combine$ = Rx.Observable.combineLatest(
  gender$,
  type$
)

我想提取这个:

.map(e => e.target).filter(t => t.nodeName === "LI").map(li => li.textContent.trim())

Answer 1

const getTextFromLis = stream$ => stream$.map(e => e.target).filter(t => t.nodeName === "LI").map(li => li.textContent.trim());

let gender$ = getTextFromLis(Rx.Observable.fromEvent(gender, 'click'));

Rx 的链接部分意味着调用 .map() 或 .filter() 将为您带来一个新流，您可以可以传递和返回函数。