koitlin 行为模式---观察者模式
简单来说，需要满足的两件事：
- 订阅者，添加或者删除 观察者的监听
- 发布者状态改变的时候，通知观察者，观察者执行相应的响应逻辑
java 自身标准提供了java.util.Observable 类和java.util.Observer接口来帮助实现观察者模式。实现一个动态更新价格的例子；
import java.util.*
class StockUpdate: Observable() {
val observers = mutableSetOf<Observer>();
fun setStockChanched(price:Int){
this.observers.forEach { it.update(this,price) }
}
}
class StockDisplay:Observer{
override fun update(o: Observable?, price: Any?) {
if(o is StockUpdate){
println("The latest stock price is $price")
}
}
}
fun main() {
val su = StockUpdate()
val sd = StockDisplay()
su.observers.add(sd)
su.setStockChanched(200)
}
Observable
Kotlin 的标准库引入了可被观察者委托属性，也可以利用来实现同样的场景
import kotlin.properties.Delegates
interface StockUpdateListener{
fun onRise(price:Int)
fun onFall(price:Int)
}
class StockDisplay2:StockUpdateListener{
override fun onRise(price: Int) {
println("The latest stock prise has risen to $price")
}
override fun onFall(price: Int) {
println("The latest stock prise has fall to $price")
}
}
class StockUpdate2{
var listeners = mutableSetOf<StockUpdateListener>()
var price:Int by Delegates.observable(0){_,old,new->
listeners.forEach {
if(new > old) it.onRise(price) else it.onFall(price)
}
}
}
fun main() {
val su = StockUpdate2()
val sd = StockDisplay2()
su.listeners.add(sd)
su.price = 100
su.price = 98
这里我们添加了功能，价格上涨和下跌观察。java.util.Observer 的接口类只能复写update方法来写相应逻辑，也就是说，如果存在多种不同的逻辑响应，我们也必须通过在改方法中进行区分实现。这回让订阅者显得臃肿。如果我们把发布者的事件推送看成一个第三方服务，那么他提供的API接口只有一个update，API调用者必须承担更多的职能。
使用Delegates.observable() 的方案更加灵活。提供了三个参数，一次代表：委托属性的元数据KProperty对象，旧值以及新值。通过额外定义一个StockUpdateListener接口，上涨和下跌的不同逻辑响应封装成了接口方法，从而，StockDisplay 中实现该接口的onRise和onFall 方法实现了解耦
Vetoable
我们有时候不希望监控的值随意更改，可能希望对某些改值的情况进行否决。Kotlin标准库除了observable这个委托属性之外，还提供了另外一个属性，vetoable，提供了功能，在被赋值前进行截获，判断是否接受。
var value:Int by Delegates.vetoable(0){
prop,old,new->
new > 0
}
>>>>
value = 1
println(value)
value = -1
println(value)
>>>>
1
1
初始值0，视图value更改为-1的时候结果仍未旧值1
