如何强制从合并发布服务器发出的事件之间的最小间隔？假设我希望所有来自上游的事件都被发出，但它们之间的间隔最小，假设为1。如果上游中两个事件之间的间隔> 1 s，则事件应按原样发出。到目前为止，我已经尝试了这样的东西：
let subject = PassthroughSubject<Int, Never>()
let result = subject.flatMap(maxPublishers: .max(1)) {
Just($0).delay(for: 1, scheduler: RunLoop.main)
}
let cancellable = result.sink {
print("--- value \($0) ---")
}
// Emitting values
subject.send(1)
DispatchQueue.main.asyncAfter(deadline: .now() + 0.3) {
subject.send(2)
}
DispatchQueue.main.asyncAfter(deadline: .now() + 0.6) {
subject.send(3)
}
DispatchQueue.main.asyncAfter(deadline: .now() + 2.5) {
subject.send(4)
}但我得到的结果是
--- value 1 ---
--- value 4 ---你知道怎么做吗？
1条答案
按热度按时间afdcj2ne1#
我不认为合并提供了一个工具，
.throttle和.debounce肯定不是你要找的。使用flatMap(maxPublishers: .max(1))将使2和3消失，因为它将阻止.delay接收它们（没有存储空间，因此您必须添加一个）。这是我发现的一个使用缓冲区的解决方案，可能会有效果：Add delay between values emitted by publisher in Combine Framework in iOS
我用你的代码进行了测试，它工作正常。