 
     /**
      Returns bindable sink, which deletes object from Realm
+
      - parameter: onError - closure to implement custom error handling
      - returns: `AnyObserver<O>`, which you can use to subscribe an `Observable` to
      */
     public static func delete<O: Object>(onError: ((O?, Error)->Void)? = nil) -> AnyObserver<O> {
-        return AnyObserver {event in
-
-            guard let element = event.element,
-                let realm = element.realm else {
-                    onError?(nil, RxRealmError.unknown)
-                    return
+
+        return AnyObserver { event in
+
+            guard let element = event.element, let realm = element.realm else {
+                onError?(nil, RxRealmError.unknown)
+                return
             }
             
             do {

            }

            return Disposables.create {
                observer.onCompleted()
                token.stop()
            }
        }

     Returns an `Observable<PropertyChange>` that emits the object `PropertyChange`s.
     
     - parameter object: A Realm Object to observe
     - returns: `Observable<PropertyChange>` will emit any time a change is detected on the object
     */
    
    public static func propertyChanges(object: Element) -> Observable<PropertyChange> {

        return Observable<PropertyChange>.create { observer in
            let token = object.addNotificationBlock { change in
                switch change {
                case .change(let changes):
                    for change in changes {
