如何在 ReactiveSwift 中中断 SafeSignal?
How to interrupt SafeSignal in ReactiveSwift?
嗨,我是反应式新手 swift。在我的新项目中,我使用的是 ReactiveSwift。我通过使用 SafeSignal 变量观察值。我想在获取值之前中断信号。请帮我解决这个问题。
一般来说,当你 observe
在 Signal
或 start
上 SignalProducer
时,你会得到 Disposable
。
这可以用来结束观察:
let property = MutableProperty<Int>(0)
let signalDisposable = property.signal.observeValues {
print("Signal: \([=10=])")
}
let producerDisposable = property.producer.startWithValues {
print("Producer: \([=10=])")
}
property.value = 1 // Signal and Producer receive value 1
signalDisposable?.dispose() // End signal observation
property.value = 2 // Only producer receives value 2
producerDisposable.dispose() // End producer observation
property.value = 3 // No one receives value 3
取消 运行 工作
如果您要为某些(较长的)工作创建自己的SignalProducer
,则必须牢记处置以停止正在进行的工作:
let performNetworkCall = SignalProducer<Data, Error> { (observer, disposable) in
let url = URL(string: "https://www.download.com")!
let downloadTask = URLSession.shared.dataTask(with: url, completionHandler: { (data, _, error) in
// Handle completion
})
downloadTask.resume()
disposable.observeEnded {
// Cancel the download on disposal!
downloadTask.cancel()
}
}
否则,你的观察者将被分离,但观察者开始的工作仍然会恢复
嗨,我是反应式新手 swift。在我的新项目中,我使用的是 ReactiveSwift。我通过使用 SafeSignal 变量观察值。我想在获取值之前中断信号。请帮我解决这个问题。
一般来说,当你 observe
在 Signal
或 start
上 SignalProducer
时,你会得到 Disposable
。
这可以用来结束观察:
let property = MutableProperty<Int>(0)
let signalDisposable = property.signal.observeValues {
print("Signal: \([=10=])")
}
let producerDisposable = property.producer.startWithValues {
print("Producer: \([=10=])")
}
property.value = 1 // Signal and Producer receive value 1
signalDisposable?.dispose() // End signal observation
property.value = 2 // Only producer receives value 2
producerDisposable.dispose() // End producer observation
property.value = 3 // No one receives value 3
取消 运行 工作
如果您要为某些(较长的)工作创建自己的SignalProducer
,则必须牢记处置以停止正在进行的工作:
let performNetworkCall = SignalProducer<Data, Error> { (observer, disposable) in
let url = URL(string: "https://www.download.com")!
let downloadTask = URLSession.shared.dataTask(with: url, completionHandler: { (data, _, error) in
// Handle completion
})
downloadTask.resume()
disposable.observeEnded {
// Cancel the download on disposal!
downloadTask.cancel()
}
}
否则,你的观察者将被分离,但观察者开始的工作仍然会恢复