RxSwift：如何在数组首次添加元素时触发Observable的completed事件

嘿，这个需求很明确，用RxSwift的几个操作符组合一下就能轻松实现。咱们直接上代码，再一步步拆解逻辑：

假设你的BehaviorSubject初始定义是这样的：

import RxSwift

let numberSubject = BehaviorSubject<[Int]>(value: [])

方法一：filter + take(1) 组合实现 #

let firstElementAddedObservable = numberSubject
    .filter { $0.count == 1 } // 只筛出数组长度刚好为1的事件
    .take(1) // 仅捕获第一个符合条件的事件，之后自动发送completed信号

方法二：用 first(where:) 更简洁 #

let firstElementAddedObservable = numberSubject
    .first { $0.count == 1 }

逻辑拆解 #

• BehaviorSubject会先发送初始化时的默认值（也就是空数组），filter会自动跳过这个长度为0的事件；
• 当你第一次给数组添加元素，让它长度变为1时，这个事件会通过filter的筛选；take(1)或first(where:)会捕获这个事件，立刻向订阅者发送completed信号，后续的数组更新就不会再触发这个Observable了；
• 如果你的BehaviorSubject初始值就已经是长度为1的数组，这个Observable会立即发送该数组并完成，完全符合“数组存在第一个元素时触发完成”的需求。

测试验证示例 #

你可以用这段代码验证效果：

let disposeBag = DisposeBag()

firstElementAddedObservable
    .subscribe(onNext: { array in
        print("收到数组：\(array)")
    }, onCompleted: {
        print("已发送completed事件")
    })
    .disposed(by: disposeBag)

// 模拟数组更新操作
numberSubject.onNext([1]) // 这里会触发onNext和onCompleted
numberSubject.onNext([1,2]) // 后续更新不会产生任何输出
numberSubject.onNext([1,2,3]) // 同样不会触发订阅回调

运行后控制台会输出：

收到数组：[1]
已发送completed事件

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