[rxjs] 怎么写一个流，让值来的时候，收集接下来一段时间的值然后发送。

This topic created in 2553 days ago, the information mentioned may be changed or developed.

我现在需要一个逻辑，当 subject 发出值之后，收集接下来 100ms 内发出的值，筛选之后再发送出去，如果使用 bufferTime 我感觉容易出现性能问题。定时器跑的太欢了，如果使用 take 就变成了下次就没结果了。

我现在的实现特么用的是睡眠排序，利用 delay 和 debounceTime 筛选出我最后要的结果。如果是正常的实现我想知道怎么做最好

筛选

定时器

发送

delay

4 replies • 2019-06-11 11:42:16 +08:00

wly19960911

Jun 11, 2019

其实我的场景是筛选出事件冒泡中更为重要的事件，比如 select 组件，open 的时候需要点击 document （或者 backdrop ）的时候关闭，问题是原有的组件逻辑里面没用 backdrop，这就可以操作其他的组件，如果这个时候如果为了阻止 document 的事件触发只能用过滤或者阻止事件冒泡。

因为原有组件逻辑问题我需要选择前者，但是过滤的时候我希望不是走过滤 document 而是收集所有被触发的事件来筛选更重要的事件....

wly19960911

Jun 11, 2019

结贴了，感觉我思路出问题了，这个过滤不应该交给中间的流来处理，我在 source 用局部变量控制下，过滤掉其他的事件就好...想法完全歪了

ookkxw

Jun 11, 2019 via iPhone

感觉你思路有问题吧，你这样设计把订阅方式变成了观察者方式，那还不如所有事件斗在一个队列里面处理，类似 react 盒合成事件

wly19960911

Jun 11, 2019

@ookkxw #3 嗯，想了下是思路的问题，我最后决定改成 filter 过滤，在执行不同事件的时候 tap 改变局部变量的值。这个时候就得开 filter 来过滤最重要的事件。

let eventActionType; // action type
merge(
fromEvent(A).pipe(
tap(() => eventActionType = A),
),
fromEvent(B).pipe(
filter(() => ....) // 根据 eventActionType 过滤
tap(() => eventActionType = B),
)
fromEvent(C).pipe(
filter(() => ....) // 根据 eventActionType 过滤
tap(() => eventActionType = C),
)
).pipe(
tap(() => eventActionType = null),
)