RxJava中BehaviorSubject用create()创建后无发射值问题求助

这个问题其实是对BehaviorSubject的特性和defaultIfEmpty操作符的触发条件理解不到位导致的，我来给你拆解清楚：

问题根源 #

• 用BehaviorSubject.create()创建的实例，初始是无缓存值的空状态，它属于"热"Observable，只有当你主动调用onNext()发送数据，或者它收到onComplete()信号时，才会有相应的行为。
• defaultIfEmpty操作符的生效逻辑是：只有当原Observable正常完成（调用onComplete()），并且完成前没有发射过任何数据时，才会发射你指定的默认值。但你的BehaviorSubject既没发送过任何数据，也没有触发完成，所以defaultIfEmpty完全不会起作用。
• 而BehaviorSubject.createDefault(...)创建的实例，会在订阅发生时，立刻把构造时传入的默认值发射给订阅者，这就是为什么它能正常工作。

解决方案 #

根据你的业务场景，有几种可行的处理方式：

1. 优先使用createDefault()（推荐） #

如果你的ViewState从一开始就应该有一个初始状态（比如页面加载中的默认UI状态），直接用createDefault()是最符合BehaviorSubject设计意图的方式：

private val viewStateSubject: BehaviorSubject<StateT> = BehaviorSubject.createDefault(createInitialState())

// 订阅逻辑保持不变，订阅时会立刻收到初始状态
viewStateDisposable = viewStateSubject
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(view::switchToState)

这种方式不需要额外的操作符，逻辑最清晰，也是RxJava推荐的BehaviorSubject初始化方式。

2. 手动发送初始状态（适合初始值需要延迟初始化的场景） #

如果因为某些原因必须用create()创建（比如初始状态依赖其他异步初始化的结果），那在初始化完成后，主动调用onNext()发送初始状态即可：

private val viewStateSubject: BehaviorSubject<StateT> = BehaviorSubject.create()

// 在合适的时机（比如ViewModel初始化完成、依赖的数据加载完成后）发送初始状态
fun initViewState() {
    viewStateSubject.onNext(createInitialState())
}

// 订阅逻辑不需要defaultIfEmpty，订阅后会收到后续发送的初始状态和其他状态
viewStateDisposable = viewStateSubject
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(view::switchToState)

3. 用startWith()替代defaultIfEmpty()（适合需要强制先显示初始状态的场景） #

如果你希望无论BehaviorSubject有没有缓存值，订阅时都先收到初始状态，之后再接收后续的状态更新，可以用startWith()操作符：

viewStateDisposable = viewStateSubject
    .startWith(createInitialState())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(view::switchToState)

注意：startWith()会在BehaviorSubject发射的所有数据之前插入初始值，即使之后BehaviorSubject有新的状态，初始值都会先被发送一次。这和defaultIfEmpty()的逻辑完全不同，要根据你的业务需求选择。

额外提醒 #

BehaviorSubject的核心特性是缓存最新的发射值，给新订阅者发送这个最新值。如果没有初始缓存值，新订阅者就不会收到任何东西，直到你调用onNext()。所以除非有特殊理由，否则尽量用createDefault()来初始化，避免这类问题。

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