RxSwift takeWhileInclusive operator

TakeWhileInclusive.swift

extension ObservableType {
    func takeWhileInclusive(predicate: @escaping (Element) throws -> Bool) -> Observable<Element> {
        let source = self.share()
        let pass = source.map(predicate).startWith(true)
        
        return Observable.zip(source, pass){ ($0, $1) }
            .takeWhile { $0.1 }
            .map { $0.0 }
    }
}