我仍在计算反应式编程,所以我很确定这是非常基本的,但是对于初学者来说,流转换的数量非常大.
我正在从DOM事件创建一个Observable.此事件应依次触发REST调用,并且在解决此事件之前,将忽略所有其他DOM事件.
const stream = Observable.fromEvent(document, 'some-event')
stream
.flatMap(() => httpRestService())
.subscribe(() => {
})
Run Code Online (Sandbox Code Playgroud)
在最后一个HTTP承诺解决之前,如何忽略流中的事件?
DOM event
A - - - - B - - - - C
HTTP event
D ...........done - C
Run Code Online (Sandbox Code Playgroud)