RxJava3：PublishSubject订阅后发送数据无输出问题及优化方案

为什么第一种方案无效？ #

PublishSubject的核心特性是只向已经完成订阅的观察者发送后续事件。你在doOnSubscribe回调里调用relay.onNext(1)时，订阅流程还未完全结束——下游的观察者还没完成和Subject的绑定注册。此时发送的事件会因为没有已订阅的观察者而被直接丢弃，所以无法打印出预期内容。

更优雅的解决办法 #

方案1：用doAfterSubscribe替代doOnSubscribe #

doAfterSubscribe会在订阅完全完成后触发回调，此时观察者已经和Subject绑定成功，发送的事件能被正常接收：

val relay = PublishSubject.create<Int>()

relay
    .doAfterSubscribe { relay.onNext(1) }
    .subscribe {
        println("Test: $it")
    }

方案2：使用startWith操作符（推荐，更贴合RxJava链式风格） #

如果只是需要在订阅后立即插入一个初始值，直接用startWith将初始值添加到流的最前端，无需手动调用onNext，代码更简洁：

val relay = PublishSubject.create<Int>()

relay
    .startWith(1)
    .subscribe {
        println("Test: $it")
    }

方案3：改用BehaviorSubject（适合需要保留初始值场景） #

BehaviorSubject会保存最后一次发送的事件，新订阅的观察者会立即收到这个最新事件。如果业务场景允许，可以直接替换PublishSubject：

// 初始化时设置默认初始值1
val relay = BehaviorSubject.createDefault(1)

relay.subscribe {
    println("Test: $it")
}

内容的提问来源于stack exchange，提问作者Lau