Observe Realm changes with RxSwift

Realm+RxSwift.swift

//
//  Realm+RxSwift.swift
//
//  Created by Carlo Eugster on 18/06/16.
//  Copyright © 2016 relaunch. All rights reserved.
//

import Foundation
import RealmSwift
import RxSwift

extension Results {
  /**
   Observable Realm Results that sends the change notification to subscribers once on query, then
   again every time a change occurs in the Results.
   */
  func asObservable() -> Observable<RealmCollectionChange<Results<Element>>> {
    return Observable.create { observer in
      var token: NotificationToken? = nil
      token = self.addNotificationBlock({ change in
        observer.onNext(change)
      })
      return AnonymousDisposable {
        token?.stop()
      }
    }
  }
}