合并 - 延迟发布者的发送

Question

当发布者在 Swift Combine 中发送一些数据时，最好的方法是什么？让我们假设以下情况：

private var publisher: PassthroughSubject<Progress, Error>

// closure called every second:
startWithProgress() { [weak self] progress in
    self.publisher.send(.init(progress: progress))

    // How to call this 0.5 second after the above `send`:
    self.publisher.send(.init(progress: progress + 0.5))
}

我检查了Delay API，但似乎我需要创建另一个发布者来使用它，这在我的情况下是次优的。我还检查了 throttle 和 debounce，但它们也不允许我一个接一个地发送 2 个更新，它们之间存在给定的延迟。

Answer 1

延迟发送值的行为（您可以使用DispatchQueue.asyncAfter）与创建延迟上游值的组合管道之间存在区别。

你没有详细说明你真正想要完成的事情，所以很难给出明确的答案。

如果我要概括一下，看起来您想要一个管道，它为每个上游值发出值，然后再次发出值 + 0.5，但延迟了。这可以像下面这样完成，例如：

let duplicateAndDelay = publisher
   .flatMap { [($0, 0), ($0 + 0.5, 0.5)].publisher } // duplicate
   .flatMap { (progress, delay) in 
      Just(progress)
         .delay(for: .seconds(delay), scheduler: RunLoop.main) // delay
   }

那你可以send一次：

startWithProgress() { [weak self] progress in
   self?.publisher.send(progress)
}

并返回要订阅的 duplicateAndDelay 发布者，而不是 publisher 发布者。

Answer 2

从您分享的内容来看，我不会使用 Combine。 DispatchQueue.asyncAfter(deadline:execute:) 好像够用了。

如果必须的话，可以使用Publisher.delay(for:tolerance:scheduler:options:)：

let subject = PassthroughSubject<Progress, Error>()
subject.delay(for: .seconds(5), scheduler: RunLoop.main)
    .replaceError(with: .init())
    .sink { progress in
        self.publisher.send(.init(progress: progress + 0.5))
    }
    .store(in: &cancellables)

甚至Publisher.publish(every:tolerance:on:in:options:)

Timer
    .publish(every: 5, on: .main, in: .default)
    .autoconnect()
    .first()
    .sink { _ in
        self.publisher.send(.init(progress: progress + 0.5))
    }

或者，如果在您的情况下有意义，则在 @Published 变量中添加 progress 并使用它来启动管道

Answer 3

我没有对此进行测试，使用计时器可能更有意义。你需要将cancellable存储在一个实例变量中，这样当函数返回时它就不会消失。

var cancellable = self.publisher
    .delay(for: .seconds(0.5), scheduler: RunLoop.main )
    .sink(receiveCompletion:{ _ in
    // do something with the error or completion
}, receiveValue:{ [unowned self] progress in
        // you don't show any code that actually updates progress, without that this will just keep sending the initial value + 0.5.
        self.publisher.send(.init(progress: progress + 0.5))
    })
self.publisher.send(.init(progress: progress))