RxSwiftCommunity/RxOptional

Observable<String?>
    .of("One", nil, "Three")
    .filterNil()
    // Type is now Observable<String>
    .subscribe { print($0) }

next(One)
next(Three)
completed

Observable<String?>
    .of("One", nil, "Three")
    .replaceNilWith("Two")
    // Type is now Observable<String>
    .subscribe { print($0) }

next(One)
next(Two)
next(Three)
completed

Observable<String?>
    .of("One", nil, "Three")
    .errorOnNil()
    // Type is now Observable<String>
    .subscribe { print($0) }

next(One)
error(Found nil while trying to unwrap type <Optional<String>>)

Observable<String?>
    .of("One", nil, "Three")
    .catchOnNil {
        return Observable<String>.just("A String from a new Observable")
    }
    // Type is now Observable<String>
    .subscribe { print($0) }

next(One)
next(A String from a new Observable)
next(Three)
completed

Observable<Int?>
    .of(5, 6, 6, nil, nil, 3)
    .distinctUntilChanged()
    .subscribe { print($0) }

next(Optional(5))
next(Optional(6))
next(nil)
next(Optional(3))
completed

Observable<[String]>
    .of(["Single Element"], [], ["Two", "Elements"])
    .filterEmpty()
    .subscribe { print($0) }

next(["Single Element"])
next(["Two", "Elements"])
completed

Observable<[String]>
    .of(["Single Element"], [], ["Two", "Elements"])
    .errorOnEmpty()
    .subscribe { print($0) }

next(["Single Element"])
error(Empty occupiable of type <Array<String>>)

Observable<[String]>
    .of(["Single Element"], [], ["Two", "Elements"])
    .catchOnEmpty {
        return Observable<[String]>.just(["Not Empty"])
    }
    .subscribe { print($0) }

next(["Single Element"])
next(["Not Empty"])
next(["Two", "Elements"])
completed

pod 'RxOptional'

github "RxSwiftCommunity/RxOptional" ~> 4.1.0

$ carthage update

import PackageDescription

let package = Package(
    name: "ProjectName",
    dependencies: [
        .Package(url: "https://github.com/RxSwiftCommunity/RxOptional")
    ]
)