RxJava Completable.andThen 永远不会触发第二个 Completable

Question

我正在尝试使用 android 上的改造链接两个返回 Completable 的反应式调用：

val userRequest = ...
val languageRequest = ...

return userService.updateUser(userRequest)
    .andThen { userService.updateMessagingUserLanguages(user.id, languageRequest) }
    .doOnComplete { userRepository.updateUser(user) }

定义如下：

@PUT("$BASE_USER_URL")
fun updateUser(@Body user: UserRequest): Completable

@PUT("$BASE_URL/{userId}/languages")
fun updateMessagingUserLanguages(@Path("userId") userId: Long, @Body request: MessagingLanguageDTO): Completable

第一个 Completable 成功并返回状态为 200 的响应。但是，第二个调用永远不会触发（它永远不会出现在我的日志中，也不会通过我的断点）。

我在这里错过了什么？

Answer 1

试试：

andThen(userService.updateMessagingUserLanguages(user.id, languageRequest))

IOW，将 lambda 表达式作为参数替换为您要添加到链中的实际 Completable。