0

我正在使用 room 和 RxAndroid 开发一个 android 应用程序。问题是我正在使用下一个代码来刷新我的回收站视图中的信息。

observable.subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe{adapter.data = it}

如果我在我的活动中实现这一点，它就像一个魅力。但是我想创建一个扩展函数，以在使用数据库中的 flowables 时使代码更清晰。我创建了这个函数

fun <T> Flowable<T>.uiSubscribe(x : (T) -> Unit)  {
this.subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe{x}

但是当我尝试使用它时，它什么也没做。它不会引发错误或任何事情。有人知道存档的方法吗？或者有人知道为什么它不起作用？

4

1 回答 1

2

您应该使用subscribe { x(it) }或subscribe(x)。

在您的情况下，subscribe{x}创建一个只在表达式中onNext声明的消费者。x

于 2018-02-08T15:40:13.497 回答