带参数的链序列可观察对象

Question

我是 RxSwift 的新手，所以我有以下问题，假设我有 3 个 Observable 示例函数，它们返回不同的 observable 类型：

func observableFunc1(item1: DummyObject) -> Observable<AVURLAsset> {
    return Observable.create { observer in

        let something_with_AVURLAsset = AVURLAsset(url: URL(fileURLWithPath: "file"))

        observer.onNext(something_with_AVURLAsset)

        observer.onCompleted()

        return Disposables.create()
    }
}

func observableFunc2(item: AVURLAsset) -> Observable<Data> {
    return Observable.create { observer in

        let something_with_data = Data()

        observer.onNext(something_with_data)

        observer.onCompleted()

        return Disposables.create()
    }
}

func observableFunc3(_ params: [String:Any]) -> Observable<Any> {
    let disposeBag = DisposeBag()
    return Observable.create { observer in
        RxAlamofire.request(api.sendData(params)).debug().subscribe(
            onNext: { reponse in
                observer.onCompleted()
        },
            onError: { error in
                observer.onError(customError.theError("error"))
        }
            )
            .addDisposableTo(disposeBag)
        return Disposables.create()
    }
}

如何依次执行这3个函数，将func1的返回值用于func2，然后在func2完成时最终运行func3。

我希望我把问题说得够清楚了，但话说回来，我对 RxSwift 还是很陌生，我不知道这些操作是否可行。

Answer 1

这是一个例子......

假设你有这三个功能：

func func1() -> Observable<Data1>
func func2(_ data: Data1) -> Observable<Data2>
func func3(_ data: Data2) -> Observable<Data3>

那么你可以：

let a = func1()
let b = a.flatMap { func2($0) }
let c = b.flatMap { func3($0) }

或：

let c = func1()
    .flatMap { func2($0) }
    .flatMap { func3($0) }

---

也就是说，你的observableFunc3 已经坏掉了。您需要从中取出处理袋。就目前而言，网络调用将在开始之前取消。

如果你真的不希望它发出任何值，那么：

func observableFunc3(_ params: [String:Any]) -> Observable<Void> {
    return RxAlamofire.request(api.sendData(params))
        .filter { false }
}

上面将发出 completed 或 error 但不会发出 next 值。

最好这样写：

func observableFunc3(_ params: [String:Any]) -> Observable<Void> {
    RxAlamofire.request(api.sendData(params))
        .map { _ in }
}

上面会发出一个next，然后是一个completed或error。这更好，因为您可以在它完成后进行映射或 flatMap 以使事情发生。