RxCloudKit is based on RxSwift

Basic usage.

privateDB.rx.save(record: ckRecord).subscribe { event in
    switch event {
        case .success(let record):
            print("record: ", record)
        case .error(let error):
            print("Error: ", error)
    }
}.disposed(by: disposeBag)

"RxCKRecord" class provides syntactic sugar for copying data (including CloudKit metadata) between CKRecord objects and plain structs.

struct MyRecord {
    var myField: String
}

extension MyRecord: RxCKRecord {
    static var zone = "MyZone"
    static var type = "MyType"
    mutating func readUserFields(from record: CKRecord) {
        // TODO 
    }
}

let myRecord = MyRecord(myField: "")
let ckRecord = try! myRecord.asCKRecord()

//

myRecord.read(from: ckRecord)

"Cache" class is an out of the box solution for maintaining a local cache of CloudKit records. Tokens are stored in UserDefaults.

var cache: Cache {
    return Cache(delegate: self, zoneIDs: ["MyZone"])
}

func application(_ application: UIApplication, didFinishLaunchingWithOptions launchOptions: [UIApplicationLaunchOptionsKey: Any]?) -> Bool {
    // Override point for customization after application launch.
    application.registerForRemoteNotifications()
    self.cache.applicationDidFinishLaunching()
    return true
}

func application(_ application: UIApplication, didReceiveRemoteNotification userInfo: [AnyHashable: Any], fetchCompletionHandler completionHandler: @escaping (UIBackgroundFetchResult) -> Void) {
    self.cache.applicationDidReceiveRemoteNotification(userInfo: userInfo, fetchCompletionHandler: completionHandler)
}

extension AppDelegate: CacheDelegate {

    public func cache(record: CKRecord) {
        // TODO store record in CoreData
    }

    public func deleteCache(for recordID: CKRecordID) {
        // TODO delete record in CoreData
    }

    public func deleteCache(in zoneID: CKRecordZoneID) {
        // TODO delete everything relevant to zone in CoreData
    }
    
    public func query(notification: CKQueryNotification, fetchCompletionHandler completionHandler: @escaping (UIBackgroundFetchResult) -> Void) {
        // TODO store/delete record in CoreData
    }

}

Carthage setup.

github "maxvol/RxCloudKit" ~> 1.0.0