JSJP_ManagerNew/Pods/RxOptional/Sources/RxOptional/Observable+Occupiable.swift

import Foundation
import RxSwift

public extension ObservableType where Element: Occupiable {
    /**
     Filter out empty occupiable elements.

     - returns: `Observable` of source `Observable`'s occupiable elements, with empty occupiable elements filtered out.
     */
    
    func filterEmpty() -> Observable<Element> {
        return self.flatMap { element -> Observable<Element> in
            guard element.isNotEmpty else {
                return Observable<Element>.empty()
            }
            return Observable<Element>.just(element)
        }
    }

    /**
     Replaces empty occupiable elements with result returned by `handler`.

     - parameter handler: empty handler throwing function that returns `Observable` of non-empty occupiable elements.

     - returns: `Observable` of the source `Observable`'s occupiable elements, with empty occupiable elements replaced by the handler's returned non-empty occupiable elements.
     */
    
    func catchOnEmpty(_ handler: @escaping () throws -> Observable<Element>) -> Observable<Element> {
        return self.flatMap { element -> Observable<Element> in
            guard element.isNotEmpty else {
                return try handler()
            }
            return Observable<Element>.just(element)
        }
    }

    /**
     Throws an error if the source `Observable` contains an empty occupiable element; otherwise returns original source `Observable` of non-empty occupiable elements.

     - parameter error: error to throw when an empty occupiable element is encountered. Defaults to `RxOptionalError.EmptyOccupiable`.

     - throws: `error` if an empty occupiable element is encountered.

     - returns: original source `Observable` of non-empty occupiable elements if it contains no empty occupiable elements.
     */
    
    func errorOnEmpty(_ error: Error = RxOptionalError.emptyOccupiable(Element.self)) -> Observable<Element> {
        return self.map { element in
            guard element.isNotEmpty else {
                throw error
            }
            return element
        }
    }
}