RxSwift合并了不同类型的Observable

Question

我应该如何Observable在RxSwift中合并两种不同类型的s？

例如:

var a: Observable<Int>
var b: Observable<Void>

Observable.of(a,b).merge() 因类型参数不同而无法实现.

Answer 1

对merge他们来说,他们需要拥有相同的类型Element.

因此,一种选择是丢弃他们的类型信息并投射到AnyObject.现在他们可以合并:

let stringSubject = PublishSubject<String>()
let stringObservable = stringSubject.asObservable().map { $0 as AnyObject }

let intSubject = PublishSubject<Int>()
let intObservable = intSubject.asObservable().map { $0 as AnyObject }

Observable.of(stringObservable, intObservable).merge()
    .subscribeNext { print($0) }
    .addDisposableTo(disposeBag)

stringSubject.onNext("a")
stringSubject.onNext("b")
intSubject.onNext(1)
intSubject.onNext(2)
stringSubject.onNext("c")

输出:

a
b
1
2
c

另一种选择是在枚举中包装:

enum Container {
    case S(String)
    case I(Int)
}

let stringSubject = PublishSubject<String>()
let stringObservable = stringSubject.asObservable().map { Container.S($0) }

let intSubject = PublishSubject<Int>()
let intObservable = intSubject.asObservable().map { Container.I($0) }

Observable.of(stringObservable, intObservable).merge()
    .subscribeNext { e in
        switch e {
        case .S(let str):
            print("next element is a STRING: \(str)")
        case .I(let int):
            print("next element is an INT: \(int)")
        }
    }
    .addDisposableTo(disposeBag)

stringSubject.onNext("a")
stringSubject.onNext("b")
intSubject.onNext(1)
intSubject.onNext(2)
stringSubject.onNext("c")

输出:

下一个元素是STRING:
下一个元素是STRING:b
下一个元素是INT:1
下一个元素是INT:2
下一个元素是STRING:c

对于可以组合Observable不同类型(如zip和combineLatest)的其他运算符,没有一个非常类似merge.但是,检查一下.它们可能更适合您的要求.

Answer 2

如果您想合并两个可观察量，但不需要 的值，并且希望有一种方法在使用该选项时Element摆脱：Expression of type 'AnyObject' is unused.map { $0 as AnyObject }

var a = PublishSubject<Int>()
var b = PublishSubject<Void>()

let observable = Observable.merge(a.map { _ in return Void() }, b)