如何解决如何创建一个联合的可观察对象，使之耗尽，但总是在电流结束后触发最后一个事件？
我要解决以下理论问题，请注意，对于我描述的示例问题，可能会有更通用的解决方案，但是我特别想知道如何创建具有这些属性的联合可观察对象。
我有一个可观察到的更改事件，这些事件应该触发保存操作（这可以观察到保存成功）。
- 我需要确保最后最后一个保存事件一定会执行。
- 保存本身是一个复杂的过程，需要一些时间，并且在保存事件期间，不应执行其他保存操作。
使用 exhaust 或exhaustMap几乎可以满足我的要求：它可以确保在保存过程中不会触发其他事件。 虽然 concat 或concatMap可以确保执行最后一个操作，但是我会做很多不必要的保存操作。
重新描述一下：如何创建一个观察对象，将耗尽并保持最后一个事件？
解决方法
您可以将throttle与配置leading: true,trailing: true一起使用来发出第一个事件，然后再发出任何事件，直到发出可观察到的事件，然后再发出在此期间收到的最后一个事件。参见How does throttleTime operator's config parameter work? (ThrottleConfig)
映射到之后要执行的可观察对象（保存操作）。保存操作完成后，使用Subject和finalize结束调节间隔。
是否使用mergeMap，exhaustMap，concatMap等映射到您的内部可观察对象都没关系，因为throttle运算符仅在您操作时发出下一个事件内部可观察完成。
如果使用此逻辑创建自定义运算符函数，则必须用defer包装代码，以便不同的订户不会共享相同的主题，而是每个订户都有自己的新主题。
export function exhaustMapWithTrailing<T,R>(
project: (value: T,index: number) => ObservableInput<R>
): OperatorFunction<T,R> {
return (source): Observable<R> => defer(() => {
const release = new Subject()
return source.pipe(
throttle(() => release,{ leading: true,trailing: true }),exhaustMap((value,index) => from(project(value,index)).pipe(
finalize(() => release.next())
) as Observable<R> )
)
})
}
events$.pipe(
exhaustMapWithTrailing(event => save(event))
)
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。