更改变量中的一个 属性 会触发对其他属性的订阅。接收迅捷
Changing one property in a variable triggers subcriptions to other properties. RxSwift
我有以下 Chat
的属性结构
struct Chat {
var id = String()
var gender = String()
var date = Date()
init() {}
}
在视图控制器中,我声明了一个名为 observablechat
的 Chat 实例,然后我使用平面图运算符尝试仅观察 date
属性 中的变化 observablechat
。但是,如果我更改性别 属性(如图所示),则会触发订阅。我想知道为什么会这样,我该如何修复此代码,以便订阅仅查看 date
属性 发生的情况,而不查看其他内容?
class ViewController: UIViewController {
var observablechat = Variable(Chat())
observablechat.asObservable()
.flatMap { (Chat) -> Observable<Date> in
return Observable.of(Chat.matchDate)
}.subscribe(onNext: { (r) in
print(r)
}).addDisposableTo(disposeBag)
self.observablechat.value.gender = "male"
//triggers subscription above.
}
}
首先,为什么flatMap
?
您只需要 distinctUntilChanged
和 map
。 DebugPrint
只会触发两次:初始设置 + 日期更改一次。查看下面的代码并随时提出问题。
import PlaygroundSupport
import RxSwift
struct Chat {
var id: String
var gender: String
var date: Date
init(id: String = "", gender: String = "", date: Date = Date(timeIntervalSince1970: 0)) {
self.id = id
self.gender = gender
self.date = date
}
}
final class YourClass {
lazy var variableChat: Variable<Chat> = Variable<Chat>(Chat())
var observableDate: Observable<Date> {
return variableChat
.asObservable()
.distinctUntilChanged({ (chatOld, chatNew) -> Bool in
return chatOld.date == chatNew.date
})
.map({ (chat) -> Date in
return chat.date
})
.shareReplay(1)
}
}
let value = YourClass()
value.observableDate
.subscribe(onNext: { (date) in
debugPrint(date.timeIntervalSince1970)
})
value.variableChat.value.gender = "male"
value.variableChat.value.date = Date()
value.variableChat.value.gender = "female"
value.variableChat.value.gender = "male"
value.variableChat.value.gender = "female"
P.S。在操场上 运行 RxSwift 的方法:readme
我有以下 Chat
struct Chat {
var id = String()
var gender = String()
var date = Date()
init() {}
}
在视图控制器中,我声明了一个名为 observablechat
的 Chat 实例,然后我使用平面图运算符尝试仅观察 date
属性 中的变化 observablechat
。但是,如果我更改性别 属性(如图所示),则会触发订阅。我想知道为什么会这样,我该如何修复此代码,以便订阅仅查看 date
属性 发生的情况,而不查看其他内容?
class ViewController: UIViewController {
var observablechat = Variable(Chat())
observablechat.asObservable()
.flatMap { (Chat) -> Observable<Date> in
return Observable.of(Chat.matchDate)
}.subscribe(onNext: { (r) in
print(r)
}).addDisposableTo(disposeBag)
self.observablechat.value.gender = "male"
//triggers subscription above.
}
}
首先,为什么flatMap
?
您只需要 distinctUntilChanged
和 map
。 DebugPrint
只会触发两次:初始设置 + 日期更改一次。查看下面的代码并随时提出问题。
import PlaygroundSupport
import RxSwift
struct Chat {
var id: String
var gender: String
var date: Date
init(id: String = "", gender: String = "", date: Date = Date(timeIntervalSince1970: 0)) {
self.id = id
self.gender = gender
self.date = date
}
}
final class YourClass {
lazy var variableChat: Variable<Chat> = Variable<Chat>(Chat())
var observableDate: Observable<Date> {
return variableChat
.asObservable()
.distinctUntilChanged({ (chatOld, chatNew) -> Bool in
return chatOld.date == chatNew.date
})
.map({ (chat) -> Date in
return chat.date
})
.shareReplay(1)
}
}
let value = YourClass()
value.observableDate
.subscribe(onNext: { (date) in
debugPrint(date.timeIntervalSince1970)
})
value.variableChat.value.gender = "male"
value.variableChat.value.date = Date()
value.variableChat.value.gender = "female"
value.variableChat.value.gender = "male"
value.variableChat.value.gender = "female"
P.S。在操场上 运行 RxSwift 的方法:readme