RxSwiftってどうなってるの？

Swift愛好会 vol23

Transcript

1. RxSwiftͬͯͲ͏ͳͬ ͯΔͷ ∁দ޾ฏ (gaopin1534)
2. ࣗݾ঺հ • ∁দ޾ฏ(gaopin1534) • ๭ਓࡐܥاۀۈ຿ • iOSྺ1೥ڧ • ΋ͱ͸PHPͱ͔Rubyͱ͔ͱ஥ྑ͠
3. RxSwift
4. ྫ͑͹WKWebView
5. self.webView?.addObserver(self, forKeyPath:"title", options:.New, context:nil) self.webView?.removeObserver(self, forKeyPath: “title”) override func observeValue(forKeyPath keyPath: String?, of object: Any?, change: [NSKeyValueChangeKey : Any]?, context: UnsafeMutableRawPointer?) { switch keyPath! { case "title": if let title = change![NSKeyValueChangeKey.newKey] as? String { self.navigationItem.title = title } default: break } }
6. webview.rx.title.bind(to: titleLabel.rx.text).addDisposableTo(disposeBag)
7. ͱͬͯ΋؆୯ by niezwyciezony(https://goo.gl/FQ3Xiy)
8. by arbyreed(https://goo.gl/m9u3VT) Ͳ͏ͳͬͯΔΜͩΖ͏
9. webview.rx.title.bind(to: titleLabel.rx.text).addDisposableTo(disposeBag)
10. public protocol ReactiveCompatible { /// Extended type associatedtype CompatibleType /// Reactive extensions. static var rx: Reactive<CompatibleType>.Type { get set } /// Reactive extensions. var rx: Reactive<CompatibleType> { get set } } extension ReactiveCompatible { /// Reactive extensions. public static var rx: Reactive<Self>.Type { get { return Reactive<Self>.self } set { // this enables using Reactive to "mutate" base type } } /// Reactive extensions. public var rx: Reactive<Self> { get { return Reactive(self) } set { // this enables using Reactive to "mutate" base object } } }
11. extension NSObject: ReactiveCompatible { }
12. public struct Reactive<Base> { /// Base object to extend. public let base: Base /// Creates extensions with base object. /// /// - parameter base: Base object. public init(_ base: Base) { self.base = base } }
13. extension Reactive where Base: WKWebView { /** Reactive wrapper for `title` property */ public var title: Observable<String?> { return self.observe(String.self, "title") } /** Reactive wrapper for `loading` property. */ public var loading: Observable<Bool> { return self.observe(Bool.self, "loading") .map { $0 ?? false } } ~தུ~ }
14. public func observe<E>(_ type: E.Type, _ keyPath: String, options: NSKeyValueObservingOptions = [.new, .initial], retainSelf: Bool = true) -> Observable<E?> { return KVOObservable(object: base, keyPath: keyPath, options: options, retainTarget: retainSelf).asObservable() }
15. extension ObservableType { /// Default implementation of converting `ObservableType` to `Observable`. public func asObservable() -> Observable<E> { // temporary workaround //return Observable.create(subscribe: self.subscribe) return Observable.create { o in return self.subscribe(o) } } }
16. func subscribe<O : ObserverType>(_ observer: O) -> Disposable where O.E == Element? { let observer = KVOObserver(parent: self) { (value) in if value as? NSNull != nil { observer.on(.next(nil)) return } observer.on(.next(value as? Element)) } return Disposables.create(with: observer.dispose) }
17. fileprivate final class KVOObserver : _RXKVOObserver , Disposable { typealias Callback = (Any?) -> Void var retainSelf: KVOObserver? = nil init(parent: KVOObservableProtocol, callback: @escaping Callback) { #if TRACE_RESOURCES _ = Resources.incrementTotal() #endif super.init(target: parent.target, retainTarget: parent.retainTarget, keyPath: parent.keyPath, options: parent.options, callback: callback) self.retainSelf = self } override func dispose() { super.dispose() self.retainSelf = nil } deinit { #if TRACE_RESOURCES _ = Resources.decrementTotal() #endif } }
18. -(instancetype)initWithTarget:(id)target retainTarget:(BOOL)retainTarget keyPath:(NSString*)keyPath options:(NSKeyValueObservingOptions)options callback:(void (^)(id))callback { self = [super init]; if (!self) return nil; self.target = target; if (retainTarget) { self.retainedTarget = target; } self.keyPath = keyPath; self.callback = callback; [self.target addObserver:self forKeyPath:self.keyPath options:options context:nil]; return self; } ΍ͬͱKVOͷΦϒβʔϒ
19. -(void)observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object change:(NSDictionary *)change context:(void *)context { @synchronized(self) { self.callback(change[NSKeyValueChangeNewKey]); } }
20. ·ͱΊ
21. WKWebView ४ڌ ReactiveCompatible Rx: Reactive Reactive title: Observable ۩৅ KVOObservable func asObservable() func subscribe() KVOObserver super init() Observableத਎ ࣮ࡍͷ஋؂ࢹ _RXKVOObserver init() func observeValueForKeyPath()
22. ·ͱΊ • ͱͯ΋ճΓ͘Ͳ͍ • ͕ɺ͓͔͛ͰKVOͱ͔gestureRecognize༝དྷ ͷ஋ΛɺιʔεΛҙࣝ͠ͳ͍ͰObserveͰ͖ Δʂ • ΈΜͳ΋RxSwiftΛ࢖͓͏ʂʂ