Observable API for KVO

psharanda · Oct 15, 2018 · bbfdc9b · bbfdc9b
1 parent 87f51da
commit bbfdc9b
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/Sources/Foundation/NSObject+Jetpack.swift b/Sources/Foundation/NSObject+Jetpack.swift
@@ -125,6 +125,19 @@ extension JetpackExtensions where Base: NSObject {
             return DisposeBag()
         }
     }
+
+    public func observed<Value>(_ sourceKeyPath: KeyPath<Base,Value>) -> Observable<Value>
+    {
+        return Observable { observer in
+            let observation = self.base.observe(sourceKeyPath, options: [.initial, .new]) { object, change in
+                guard let newValue = change.newValue else { return }
+                observer(newValue)
+            }
+            return BlockDisposable {
+                observation.invalidate()
+            }
+        }
+    }
 }
 
 extension NSObject: JetpackExtensionsProvider {}