消费者在kotlin中表现怪异

我只是回到Kotlin（从Java过渡），我注意到使用Consumer比听起来更棘手。

 class EventBus(controller: Controller) { private val consumerMap : MutableMap<KClass<out Event>, MutableSet<Consumer<out Event>>> = ConcurrentHashMap() private val controller : Controller = controller public fun <T : Event> register(clazz: KClass<T>, handler: Consumer<T>) { consumerMap.getOrPut(clazz, { HashSet() }).add(handler) } public fun <T : Event> post(event : T) { consumerMap[event.javaClass.kotlin]?.forEachIndexed { i, handler -> controller.getLogger().trace("Firing handler ${i + 1} for event ${event.javaClass.name}") handler.accept(event) } } } 

我试图做一个简单的类来解雇基本事件，唯一的问题是根据IntelliJ的接受方法不存在。 然而，当我试图创建一个新的消费者，并立即使用它的接受方法在那里，并按预期工作。

http://pksv.co/go/myOeEvTE

有什么我可能错过或忽略了？

Answer 1

我傻。 我已经把Java钻了这么久了。 用(Event) -> Unit代替Consumer<out Event> （和其他Consumer用途(Event) -> Unit清除了一切！

对于任何对代码感兴趣的人：

 class EventBus(controller: Controller) { private val consumerMap : MutableMap<KClass<out Event>, MutableSet<(Event) -> Unit>> = ConcurrentHashMap() private val controller : Controller = controller public fun <T : Event> register(clazz: KClass<T>, handler: (T) -> Unit) { consumerMap.getOrPut(clazz, { HashSet() }).add(handler as (Event) -> Unit) // hacky cast :-) } public fun <T : Event> post(event : T) { consumerMap[event.javaClass.kotlin]?.forEachIndexed { i, handler -> controller.getLogger().trace("Firing handler ${i + 1} for event ${event.javaClass.name}") handler.invoke(event) } } }