如何取消订阅 TornadoFX 中的事件？

Question

在 TornadoFX 中，我想取消订阅一个自定义事件，这样接收方就不会再处理不必要的事件，并且可能会避免内存泄漏之类的事情，但是，当我在我的代码中使用 unsubscribe<MyEvent> 方法时，它根本不起作用。这是我的代码的一部分：

object MyEventObj: FXEvent(EventBus.RunOn.BackgroundThread)
class MyEventBus(val personlist:List<PersonOld>): FXEvent()
class MyController: Controller()
{
    init
    {
        subscribe<MyEventObj> {
            unsubscribe<MyEventObj> { 
                println("Unsubscribe event!") //unsubscrib event and make sure the next code just runs once, but never works!
            }
            println("Event has received!")
            val items = listOf(PersonOld("Name A", 20), PersonOld("Name B", 25))
            fire(MyEventBus(items))
        }
    }
}

所以，问题是什么？以及如何在 TornadoFX 中使用 unsubscribe？感谢您提前帮助我！

Answer 1

unsubscribe 函数将事件侦听器作为唯一参数。因此，为了能够取消订阅，您需要将侦听器保存为成员 val，以便您可以引用它。更有趣的是，您不能在侦听器本身内部引用 this，因此您需要调用另一个函数才能成功取消订阅。这是一个完整的例子：

object MyEvent : FXEvent()

class MyView : View() {
    override val root = stackpane {
        paddingAll = 100
        button("Fire!") {
            setOnAction {
                fire(MyEvent)
            }
        }
    }

    val myListener: (MyEvent) -> Unit = {
        alert(Alert.AlertType.INFORMATION, "Event received!", "This message should only appear once.")
        stopListening()
    }

    init {
        subscribe(myListener)
    }

    fun stopListening() = unsubscribe(myListener)

}

如果可以从自身内部引用监听器，我们可以直接在监听器内添加一个 unsubscribe() 调用，但这是不可能的，至少在 Kotlin 1.0 中是不可能的。

编辑： 我们刚刚添加了一个 times = n 参数来订阅，因此您无需自己处理注销。默认情况下，每次事件触发时都会触发事件侦听器，但通过传递 1，您可以在第一次后自动注销。有了 TornadoFX 1.6.3 中的这个新功能，您可以简单地改为这样做：

class MyView : View() {
    override val root = stackpane {
        paddingAll = 100
        button("Fire!") {
            setOnAction {
                fire(MyEvent)
            }
        }
    }

    init {
         subscribe<MyEvent>(times = 1) {
            alert(Alert.AlertType.INFORMATION, "Event received!", "This message should only appear once.")
        }
    }

}

EDIT2: TornadoFX 1.6.3 还将引入触发器操作的 EventContext，因此您可以在下一个版本的事件监听器。然后您可以将此作为 times 参数的替代方法：

subscribe<MyEvent> {
    alert(Alert.AlertType.INFORMATION, "Event received!", "This message should only appear once.")
    unsubscribe()
}

如何取消订阅 TornadoFX 中的事件？

How to unsubscribe events in TornadoFX?

java

events

kotlin

unsubscribe

tornadofx