gpt4 book ai didi

javascript - 刷新 RxJs 主题

转载 作者:行者123 更新时间:2023-11-29 23:17:28 24 4
gpt4 key购买 nike

我想创建一个带有 bufferTime 管道的主题。例如

subject.pipe(bufferTime(1000, null, this._bufferSize),
filter((v, i) => {
return v.length !== 0;
})
)

在使用这个主题并完成工作后,我希望用户调用 onComplete/new 方法来刷新流的剩余内容。

因为这是基于时间的,所以我可以等待流自行刷新,但因为我使用的是 AWS Lambda 运行时,所以很花钱。

有没有简单的方法来实现同花顺?

最佳答案

我想你在找takeUntil运算符(operator):

const subject = new Subject();
const complete = new Subject();
const BUFFER_SIZE = 10;

subject
.pipe(
takeUntil(complete),
bufferTime(1000, null, BUFFER_SIZE),
)
.subscribe(buffer => {
console.log(Date.now(), buffer);
});

我使用另一个名为 completeSubject,它用于完成 Observable 并随后在 bufferTime 中刷新缓冲区。

请参阅此处的工作示例:https://stackblitz.com/edit/typescript-ihjbxb

关于javascript - 刷新 RxJs 主题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52216125/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com