RxSwiftオプションの便利な機能をアンラップしますか？

Question

現在ストリーム内のオプションの入力を安全にアンラップするために、関数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) 
    } 
} 

を私が実行しようとしましたが、それはコンパイルすることはありません何か

Answer 1

あなたはその観測上の唯一の仕事へunwrapOptional方法をしたいですオプションのタイプがあります。

ElementのObservableをどうにかしてOptionalプロトコルに準拠させる必要があります。

extension Observable where Element: OptionalType { 
    /// Returns an Observable where the nil values from the original Observable are 
    /// skipped 
    func unwrappedOptional() -> Observable<Element.Wrapped> { 
     return self.filter { $0.asOptional != nil }.map { $0.asOptional! } 
    } 
} 

残念ながら、Swiftはこのようなプロトコル（OptionalType）を定義していません。あなた自身もそれを定義する必要があります

/// Represent an optional value 
/// 
/// This is needed to restrict our Observable extension to Observable that generate 
/// .Next events with Optional payload 
protocol OptionalType { 
    associatedtype Wrapped 
    var asOptional: Wrapped? { get } 
} 

/// Implementation of the OptionalType protocol by the Optional type 
extension Optional: OptionalType { 
    var asOptional: Wrapped? { return self } 
} 

Answer 2

チェックアウトunwraphttps://github.com/RxSwiftCommunity/RxSwift-Ext :)

または今のhttps://github.com/RxSwiftCommunity/RxOptional

、あなたはしかし、RxSwift-Extは、次の2〜3ヶ月での指数関数的な成長となり、あなたの個人的なニーズ
ためを使用する必要があります:)