【发布时间】:2016-04-19 05:41:16
【问题描述】:
目前我创建了一个函数unwrapOptional 来安全地解开流中的可选输入。
func unwrapOptional<T>(x: Optional<T>) -> Observable<T> {
return x.map(Observable.just) ?? Observable.empty()
}
let aOpt: String? = "aOpt"
_ = Observable.of(aOpt).flatMap(unwrapOptional).subscribeNext { x in print(x)}
let aNil: String? = nil
_ = Observable.of(aNil).flatMap(unwrapOptional).subscribeNext { x in print(x)}
let a: String = "a"
_ = Observable.of(a).flatMap(unwrapOptional).subscribeNext { x in print(x)}
// output
aOpt
a
我要归档的是创建一个方便的函数,而不是使用flatMap(unwrapOptional),例如
Observable.of(a).unwrapOptional()
我试图做的事情,但它永远不会编译......
extension ObservableType {
func unwrapOptional<O : ObservableConvertibleType>() -> RxSwift.Observable<O.E> {
return self.flatMap(unwrapOptional)
}
}
【问题讨论】: