kotlin - 实现类型识别的纯发布方式的纯Kotlin方法

标签 kotlin publish-subscribe

我想知道如何使用这样的API在kotlin中实现简单的发布-订阅模式:

Channel.publish(event: T)
Channel.subscribe{ event: T -> Unit)

类型意识对我很重要,因此Channel仅将T类型的事件传递给(T)->Unit类型的订户(而不传递给(S)->Unit类型等于S is T的另一个false类型的事件)

这是我的实现。
但是有两件事困扰着我。看:
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 Anysubscriber as (Any) -> Unit显得很假。我该如何摆脱呢?这个问题有可能吗?

更新1:
我找到了摆脱event as Any的解决方案
    inline fun <reified T : Any> publish(event: T) {
        subscribers[T::class]?.invoke(event)
    }

最佳答案

您的实现将在非常幼稚的情况下工作。但是,例如,上面的代码不支持单个事件类型的多个订阅者。
订阅事件的父类(super class)型的情况也是如此。 (即事件层次结构)

除非您将其构建为练习,否则建议您使用现有的实现(例如Guava's event bus)。它不是用Kotlin编写的,而是用Java编写的,但是可以与Kotlin一起流畅地工作。

关于kotlin - 实现类型识别的纯发布方式的纯Kotlin方法,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56613415/

相关文章:

kotlin - 在 Kotlin 中实现接口(interface)中声明的属性

java - 模块错误 "Module was compiled with an incompatible version of Kotlin. The binary version of its metadata is 1.5.1, expected version is 1.1.16"

android - 协程 : run a Deferred on a specific CoroutineContext

redis - 使用 Redis 进行 pub-sub 意味着什么

publish-subscribe - 如何在 gcloud pubsub 中为主题添加 protobuf 文件?

.net - 使用大文件作为消息负载进行发布/订阅

ruby-on-rails - rails 上的 Redis 发布/订阅

android - 如何在 Jetpack Compose 中实现平移 + 缩放动画?

java - 如何运行 WorkManager 每 5 秒重试一次工作

javascript - PubSub/Observer 模式中的排队事件