代码之家 › 专栏 › 技术社区 › Mangat Rai Modi

RXJava也许:有什么简单的方法来处理空盒子吗?

rx-kotlin rx-java kotlin

Mangat Rai Modi · 技术社区 · 6 年前

我被这个问题困住了,应该很简单。当 Maybe 已作为 Empty Maybe . 我发现

我们可以传递默认值或使用switchifempty,但我觉得两者都很粗糙。
此外,还有一个subscribe函数接受oncomplete函数(以及其他两个事件的处理程序),但oncomplete不接受任何参数,这些参数可用于查找may是否为空完成。
另一种方法可能是 Maybe.isEmpty.blockingGet() ,但它也很脏。

我试过跟随( Kotlin语法 ):

fun <T> Maybe<T>.subscribeWithEmptyHandler(onSuccess: (T) -> Unit, onError: (Throwable) -> Unit, onEmpty: () -> Unit) {
    this.isEmpty.subscribe({ if (it) onEmpty() }, { onError(it) })
    this.subscribe({ onSuccess(it) }, { onError(it) })
}

但正如预期的那样,它运行了两次订阅,测试如下:

Maybe.create<Int> {
    println("subscribing")
    //Remove line below to create Empty Maybe
    it.onSuccess(5)
    it.onComplete()
}
    .subscribeWithEmptyHandler({println("success")},{println("error")},{println("empty")})

有人能提出更简洁的方法来解决这个问题吗?

2 回复 | 直到 6 年前

Dave Moten 6 年前

使用 Maybe.doOnEvent (Java示例):

Maybe
 .empty()
 .doOnEvent((value, error)-> {
    if (value==null && error == null) {
      System.out.println("empty!");
    }})
 .subscribe();

Mangat Rai Modi 6 年前

我所做的下列事情比我在问题中所写的任何事情都要整洁:

fun <T> Maybe<T>.subscribeWithEmptyHandler(onSuccess: (T) -> Unit, onError: (Throwable) -> Unit, onEmpty: () -> Unit) {
    this.toSingle()
        .subscribe(
            { onSuccess(it) },
            { if (it is NoSuchElementException) onEmpty() else onError(it) }
        )
}

这里它只订阅一次,不需要创建新的默认值。仍然不确定这是否是最好的方法。

推荐文章

danny · 如何在kotlin中使用图形2d与paint()

1 年前

manabreak · 如何在Jetpack Compose中通过叠加可组合的拖拽交互,但捕捉点击交互?

1 年前

danilo · Android在谷歌sigin中使用Firebase Auth时没有sigin

1 年前

Murad Axundov · 我的功能只有一小部分有效。怎样(科特林)

2 年前

Vetalll · Java、JDBC在重复密钥更新通配符上的插入

2 年前

jvargas · 如何获取上个月的第一天和最后一天以及一年的第一天

2 年前

Michel · 在Android上后台播放音频超过一分钟

2 年前

mepi0011 · Android Studio中的Kotlin持续时间问题

2 年前

Ashish Joshi · 未使用导航图弹出片段

2 年前

Tommy - · 为什么回收器视图在片段中有NullPointerException?

2 年前