RxSwift中传递联系人数据时如何在后台赋值nextPage？

这问题我实际开发中碰到过，核心就是把副作用操作（赋值nextPage）和数据传递拆解开，同时把赋值逻辑放到后台线程执行，还不能影响后续的数据流转。给你一个清晰的实现方案：

基础实现版本 #

retrieveContacts()
    .subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))
    // 在后台线程处理nextPage赋值，同时保留联系人数据传递
    .flatMap { [weak self] contacts, nextPage -> Observable<[Contact]> in
        // 这里的代码会在subscribeOn指定的后台线程执行
        self?.nextPage = nextPage
        // 返回包装好的联系人数据，让后续流程能拿到
        return Observable.just(contacts)
    }
    .observeOn(MainScheduler.instance)
    .subscribe(onNext: { contacts in
        // 主线程处理UI相关的联系人展示逻辑
    })
    .disposed(by: disposeBag)

多Observable共享数据版本 #

如果需要把联系人数据传递给多个不同的Observable（比如UI层和业务逻辑层），可以把这个流抽成共享的Observable，避免重复发起请求：

// 抽成共享的Observable，用share(replay:1)避免重复订阅触发多次请求
let contactsObservable = retrieveContacts()
    .subscribeOn(ConcurrentDispatchQueueScheduler(qos: .background))
    .flatMap { [weak self] contacts, nextPage -> Observable<[Contact]> in
        self?.nextPage = nextPage
        return Observable.just(contacts)
    }
    .observeOn(MainScheduler.instance)
    .share(replay: 1)

// UI层订阅
contactsObservable.subscribe(onNext: { contacts in
    // 更新联系人列表UI
}).disposed(by: disposeBag)

// 其他业务逻辑订阅
contactsObservable.subscribe(onNext: { contacts in
    // 比如同步联系人到本地缓存
}).disposed(by: disposeBag)

逻辑说明 #

• 利用flatMap在后台线程处理副作用：因为subscribeOn已经指定了后台调度器，flatMap内的代码会自动在后台执行，完美满足你要在后台赋值nextPage的需求。
• 数据流转不受影响：flatMap返回包装后的联系人数据Observable，后续的observeOn和subscribe能正常拿到数据处理UI或其他逻辑。
• 避免多余线程切换：如果在原来的主线程onNext里再切后台赋值，会多一次线程上下文切换，现在的方案直接在后台完成赋值，更高效。

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