如何使用 kotlinx-coroutines-reactive 处理空场景？

Question

kotlinx-coroutines-reactive 使org.reactivestreams.Publisher 拥有awaitXXX 方法：

val person = peopleReactiveRepository.findById(personId).awaitSingle()

如果通过人员 ID 找不到人员，则此调用将抛出 NoSuchElementException 并且无法在用户代码中直接处理此异常。并且 Spring MVC ExceptionHandler 无法将此异常转换为用户友好的响应。

java.util.NoSuchElementException: No value received via onNext for awaitSingle
at kotlinx.coroutines.experimental.reactive.AwaitKt$awaitOne$$inlined$suspendCancellableCoroutine$lambda$1.onComplete(Await.kt:131) ~[kotlinx-coroutines-reactive-0.22.1.jar:na]
at reactor.core.publisher.StrictSubscriber.onComplete(StrictSubscriber.java:123) ~[reactor-core-3.1.2.RELEASE.jar:3.1.2.RELEASE]
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:1327) ~[reactor-core-3.1.2.RELEASE.jar:3.1.2.RELEASE]
at reactor.core.publisher.FluxHide$SuppressFuseableSubscriber.onComplete(FluxHide.java:137) ~[reactor-core-3.1.2.RELEASE.jar:3.1.2.RELEASE]
at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:130) ~[reactor-core-3.1.2.RELEASE.jar:3.1.2.RELEASE]
at reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:96) ~[reactor-core-3.1.2.RELEASE.jar:3.1.2.RELEASE]
at com.mongodb.reactivestreams.client.internal.ObservableToPublisher$1.onComplete(ObservableToPublisher.java:78) ~[mongodb-driver-reactivestreams-1.6.0.jar:na]

我能想到的方法之一如下：

val person = peopleRepository.findById(personId).awaitFirstOrDefault(null)

if (person == null) {
    // do something
}

但我不认为这是一种优雅的方式。例如，可以提供一个名为awaitSingleOptional的方法。

有没有更好的 Kotlin 方法来处理这种情况？

Answer 1

Kotlin 中没有标准的 Optional 包装器。对于这种情况，您可以使用the let function：

val person = peopleRepository.findById(personId).awaitFirstOrDefault(null)?.let {
    // do
}

如果 await 表达式的计算结果为默认 null，则 let 调用也将计算结果为 null。如果需要处理这种情况，可以使用Elvis operator：

.let {...} ?: throw IllegalStateException()

Answer 2

如果您以函数式方式编程，您绝对可以使用 Optional 包装器。

如果您想通过函数式编程来沾沾自喜，您可以选择具有 Option 和 Try 数据类型的 Arrow。

使用?.let 是另一种选择，但它对响应式编程没有多大帮助。

ReactiveX 中还有 Notification 类，如果你在做 Railway Oriented Programming，它可以让你处理错误的场景。

Answer 3

在最近的kotlinx.coroutines 版本0.22.2 中提供了扩展awaitFirstOrNull()。看到这个PR。

取自发行说明：

响应式：添加了 awaitFirstOrDefault 和 awaitFirstOrNull 扩展（参见 #224，@konrad-kaminski 的 PR）。