【发布时间】:2019-05-28 14:21:00
【问题描述】:
我正在尝试使用 RxSwift 订阅 3 种不同的 BehaviorRelay。思路如下:
let disposeBag = DisposeBag()
class ClassA{
var br1 = BehaviorRelay(value: "BR1_1")
var br2 = BehaviorRelay(value: "BR2_1")
var br3 = BehaviorRelay(value: "BR3_1")
/* Some other variables */
}
let classA = ClassA()
class ClassB:CustomStringConvertible{
let classA:ClassA
var description: String{
return "\(br1.value), \(br2.value), \(br3.value)"
}
var br1:BehaviorRelay<String>{
return classA.br1
}
var br2:BehaviorRelay<String>{
return classA.br2
}
var br3:BehaviorRelay<String>{
return classA.br3
}
init(classA:ClassA) {
self.classA = classA
}
}
let classB = ClassB(classA: classA)
classB.br1.asObservable().subscribe { (value) in
print(value)
}
classA.br1.accept("BR1_2")
打印出来:
next(BR1_1)
next(BR1_2)
通过这样做,我将使用 ClassA 中的对象“填充”我的 ClassB,并通过设置对 ClassB 中的对象的订阅,我可以对下一个事件做出反应。
但是,我想创建一个函数,例如:
func reactingFunction(br1:BehaviorRelay<String>, br2:BehaviorRelay<String>, br3:BehaviorRelay<String>){
/**/
}
每次 br 产生 onNext 事件时调用。我可以为所有人创建一个混合订阅吗?
谢谢
【问题讨论】:
标签: rx-swift