我想知道如何用这样的API在kotlin中实现一个简单的发布-订阅模式:
Channel.publish(event: T)
Channel.subscribe{ event: T -> Unit)类型识别对我来说很重要,这样Channel只会将T类型的事件传递给(T)->Unit类型的订阅者(而不是另一个S is T等于false的(S)->Unit类型的订阅者)。
这是我的实现。但有两件事困扰着我。看:
import kotlin.reflect.KClass
object Channel {
private val subscribers: MutableMap<KClass<*>, (Any) -> Unit> = mutableMapOf()
inline fun <reified T> publish(event: T) {
subscribers[T::class]?.invoke(event as Any)
}
inline fun <reified T> subscribe(noinline subscriber: (T) -> Unit) {
subscribers[T::class] = subscriber as (Any) -> Unit
}
}
data class Person(val name: String)
fun main() {
Channel.subscribe { person: Person -> println("Hello ${person.name}") }
Channel.publish(Person("John"))
}在我看来,event as Any和subscriber as (Any) -> Unit的造型都是假的。我怎么才能摆脱这个?在这个问题上有可能吗?
更新#1:我找到了一个摆脱event as Any的解决方案
inline fun <reified T : Any> publish(event: T) {
subscribers[T::class]?.invoke(event)
}发布于 2019-06-16 08:26:42
您的实现将适用于一个非常天真的案例。但是,例如,上面的代码不支持单个相同事件类型的多个订阅者。订阅事件的超级类型的情况也是如此。(即事件层次结构)
除非您将其构建为练习,否则我建议您使用像番石榴事件总线这样的现有实现。它不是用Kotlin编写的,而是用Java编写的,但是它与Kotlin一起工作很顺利。
https://stackoverflow.com/questions/56613415
复制相似问题