CDObservable_init.swift

import CoreData
import Foundation
import os.log
import RxCocoa
import RxSwift

class CDObservable<T>: NSObject, ObservableType, NSFetchedResultsControllerDelegate where T: NSManagedObject {
    private var fetchedResultsController: NSFetchedResultsController<NSManagedObject>?
    private let context: NSManagedObjectContext
    private let fetchRequest: NSFetchRequest<T>
    private let results = BehaviorSubject<[T]>(value: [])
    private var subscriptions = 0
    private let serialQueue = DispatchQueue(label: "com.RxFetcher")

    typealias Element = [T]

    init(fetchRequest: NSFetchRequest<T>, context: NSManagedObjectContext) {
        if fetchRequest.sortDescriptors == nil {
            fetchRequest.sortDescriptors = []
        }

        self.fetchRequest = fetchRequest
        self.context = context
        super.init()
    }
}