RxSwift：API调用完成前跳过源序列事件的实现方案咨询

你用skipUntil失败的原因很明确：这个操作符的逻辑是仅跳过源序列事件直到trigger发出第一个事件，一旦trigger发过一次，后续源序列的所有事件都会直接通过，所以你后面的trigger事件完全起不到作用。

针对你的需求——处理事件时发起API调用，API未完成前跳过所有新事件，完成后再接收下一个——最贴合的操作符是flatMapFirst，它的核心特性就是：当有一个内部Observable（即你的API请求）在执行时，会忽略源序列新发出的事件，直到当前内部Observable完成，才会处理下一个源事件。

示例代码 #

import UIKit
import RxSwift
import RxSwiftPlayground

let disposeBag = DisposeBag()
let subject = PublishSubject<String>()

// 模拟实际API调用：接收事件后延迟1秒模拟请求耗时
func performAPIRequest(for event: String) -> Observable<Void> {
    print("开始处理事件: \(event)")
    return Observable.just(())
        .delay(.seconds(1), scheduler: MainScheduler.instance)
        .do(onCompleted: {
            print("事件 \(event) 处理完成")
        })
}

subject
    .flatMapFirst { event in
        // 用flatMapFirst包裹API请求，确保同一时间仅一个请求执行
        performAPIRequest(for: event)
            .map { event } // 将API结果映射回原事件，方便订阅者获取原始数据
    }
    .subscribe(onNext: { processedEvent in
        print("订阅收到处理完成的事件: \(processedEvent)")
    })
    .disposed(by: disposeBag)

// 测试事件发射逻辑
subject.onNext("A")
subject.onNext("B") // 此时A的API还在处理，B被跳过
subject.onNext("C") // 同样被跳过

DispatchQueue.main.asyncAfter(deadline: .now() + 1.2) {
    subject.onNext("D") // A处理完成，D开始被处理
    subject.onNext("E") // D的API处理中，E被跳过
}

代码说明 #

• flatMapFirst会自动帮你管理并发：只要有一个API请求在执行，源序列新发来的事件都会被直接忽略，直到当前请求完成
• performAPIRequest是你的实际API请求逻辑，只需返回一个代表请求生命周期的Observable（比如用URLSession.rx.data发起网络请求）
• 用map { event }把API请求的结果映射回原始事件，这样订阅者能拿到最初的事件数据进行后续处理

替代方案（手动状态控制） #

如果你需要更精细的状态控制，也可以用scan结合filter实现，但逻辑相对繁琐：

let processingTrigger = PublishSubject<Void>()

subject
    .merge(with: processingTrigger.map { _ in nil })
    .scan((isProcessing: false, pendingEvent: nil as String?)) { state, newEvent in
        if let event = newEvent {
            return state.isProcessing ? state : (isProcessing: true, pendingEvent: event)
        } else {
            // 处理完成，重置状态
            return (isProcessing: false, pendingEvent: nil)
        }
    }
    .compactMap { $0.pendingEvent }
    .flatMap { event in
        performAPIRequest(for: event)
            .map { event }
            .do(onCompleted: {
                processingTrigger.onNext(())
            })
    }
    .subscribe(onNext: { processedEvent in
        print("订阅收到处理完成的事件: \(processedEvent)")
    })
    .disposed(by: disposeBag)

这种方式通过额外的processingTrigger来重置处理状态，但显然不如flatMapFirst简洁高效，优先推荐前者。

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