1- //
2- // FetchedResultsControllerEntityObserver.swift
3- // RxCoreData
4- //
5- // Created by Krunoslav Zaher on 5/18/16.
6- // Copyright © 2016 Krunoslav Zaher. All rights reserved.
7- //
8-
91import Foundation
102import CoreData
113import RxSwift
@@ -14,9 +6,8 @@ public final class FetchedResultsControllerEntityObserver<T: NSManagedObject> :
146
157 typealias Observer = AnyObserver < [ T ] >
168
17- fileprivate let observer : Observer
18- fileprivate let disposeBag = DisposeBag ( )
19- fileprivate let frc : NSFetchedResultsController < T >
9+ private let observer : Observer
10+ private let frc : NSFetchedResultsController < T >
2011
2112
2213 init ( observer: Observer , fetchRequest: NSFetchRequest < T > , managedObjectContext context: NSManagedObjectContext , sectionNameKeyPath: String ? , cacheName: String ? ) {
@@ -39,7 +30,7 @@ public final class FetchedResultsControllerEntityObserver<T: NSManagedObject> :
3930 }
4031 }
4132
42- fileprivate func sendNextElement( ) {
33+ private func sendNextElement( ) {
4334 self . frc. managedObjectContext. perform {
4435 let entities = self . frc. fetchedObjects ?? [ ]
4536 self . observer. on ( . next( entities) )
@@ -49,12 +40,12 @@ public final class FetchedResultsControllerEntityObserver<T: NSManagedObject> :
4940 public func controllerDidChangeContent( _ controller: NSFetchedResultsController < NSFetchRequestResult > ) {
5041 sendNextElement ( )
5142 }
43+ /// Delegate implementation for `Disposable`
44+ /// required methods - This is kept in here
45+ /// to make `frc` private.
46+ public func dispose( ) {
47+ frc. delegate = nil
48+ }
5249}
5350
54- extension FetchedResultsControllerEntityObserver : Disposable {
55-
56- public func dispose( ) {
57- frc. delegate = nil
58- }
59-
60- }
51+ extension FetchedResultsControllerEntityObserver : Disposable { }
0 commit comments