ReactiveSwift 从数组中发射元素,元素之间有延迟
ReactiveSwift emit elements from an array with a delay between elements
假设我有一个元素数组 [1, 2, 3]
和 5
秒的延迟。
我想发射数组的每个元素,在发射的当前元素和下一个元素之间有一个停顿。
示例:
输出:
[00:00] -- 1
[00:05] -- 2
[00:10] -- 3
我已尝试执行以下操作:
import ReactiveSwift
let startTime = DispatchTime.now().uptimeNanoseconds
let arrayProperty = MutableProperty<[Int]>([1, 2, 3])
let arraySignal = arrayProperty.signal
arraySignal
.flatMap { [=11=] }
.delay(2, on: QueueScheduler.main)
.observeValues { element in
let elapsed = DispatchTime.now().uptimeNanoseconds
print("\((elapsed - startTime) / 1_000_000_000) -- \(element)")
}
但它只会延迟第一个元素的发射,并立即发射下一个元素。
我找不到合适的运算符组合来使用,也许 ReactiveSwift 框架上缺少它们,而且我是响应式编程的初学者,所以实现我自己的运算符还太难了。
我还没有机会尝试这段代码,但它应该是这样的:
SignalProducer([1, 2, 3])
.flatMap(.concat) { n in
return SignalProducer(value: n).delay(2, on: QueueScheduler.main)
}
.startWithValues { element in
let elapsed = DispatchTime.now().uptimeNanoseconds
print("\((elapsed - startTime) / 1_000_000_000) -- \(element)")
}
关键是您使用 flatMap
为每个可以应用延迟的值创建一个新的信号生成器,并将它们与 .concat
展平策略相结合。
(另外,请注意,您可以使用带有序列的信号生成器初始化程序)
假设我有一个元素数组 [1, 2, 3]
和 5
秒的延迟。
我想发射数组的每个元素,在发射的当前元素和下一个元素之间有一个停顿。
示例:
输出:
[00:00] -- 1
[00:05] -- 2
[00:10] -- 3
我已尝试执行以下操作:
import ReactiveSwift
let startTime = DispatchTime.now().uptimeNanoseconds
let arrayProperty = MutableProperty<[Int]>([1, 2, 3])
let arraySignal = arrayProperty.signal
arraySignal
.flatMap { [=11=] }
.delay(2, on: QueueScheduler.main)
.observeValues { element in
let elapsed = DispatchTime.now().uptimeNanoseconds
print("\((elapsed - startTime) / 1_000_000_000) -- \(element)")
}
但它只会延迟第一个元素的发射,并立即发射下一个元素。
我找不到合适的运算符组合来使用,也许 ReactiveSwift 框架上缺少它们,而且我是响应式编程的初学者,所以实现我自己的运算符还太难了。
我还没有机会尝试这段代码,但它应该是这样的:
SignalProducer([1, 2, 3])
.flatMap(.concat) { n in
return SignalProducer(value: n).delay(2, on: QueueScheduler.main)
}
.startWithValues { element in
let elapsed = DispatchTime.now().uptimeNanoseconds
print("\((elapsed - startTime) / 1_000_000_000) -- \(element)")
}
关键是您使用 flatMap
为每个可以应用延迟的值创建一个新的信号生成器,并将它们与 .concat
展平策略相结合。
(另外,请注意,您可以使用带有序列的信号生成器初始化程序)