ReactiveKit+Realm

ReactiveKit+Realm.swift

import ReactiveKit
import RealmSwift

extension ReactiveExtensions where Base: RealmCollection {

    var changes: SafeSignal<Base> {
        return SafeSignal<Base> { observer in
            let realmToken = self.base.addNotificationBlock { changes in
                switch changes {
                case .initial(let new), .update(let new, _, _, _):
                    observer.next(new)
                case .error:
                    break
                }
            }

            return BlockDisposable {
                realmToken.stop()
            }
        }
    }

}