 
 // MARK: - Reactive
 
-extension Reactive where Base == DataStack {
+public extension Reactive where Base == DataStack {
     
     /**
      Reactive extension for `CoreStore.DataStack`'s `monitorList(...)` API. Creates an observable that wraps a `ListMonitor` that satisfies the specified fetch clauses. Multiple subscriptions be notified when changes are made to the list. The observable element will contain an `RxListChange` value.

     - parameter fetchClauses: a series of `FetchClause` instances for fetching the object list. Accepts `Where`, `OrderBy`, and `Tweak` clauses.
     - returns: An `Observable` for changes in the list. If multiple subscriptions need to share the same `ListMonitor`, it is recommended that the `Observable` returned from this method be shared using `RxSwift`'s `Observable.share()` method.
     */
    func monitorList<D: DynamicObject>(_ from: From<D>, _ fetchClauses: FetchClause...) -> Observable<RxListChange<D>> {
        
        return self.monitorList(from, fetchClauses)
    }

     - parameter fetchClauses: a series of `FetchClause` instances for fetching the object list. Accepts `Where`, `OrderBy`, and `Tweak` clauses.
     - returns: An `Observable` for changes in the list. If multiple subscriptions need to share the same `ListMonitor`, it is recommended that the `Observable` returned from this method be shared using `RxSwift`'s `Observable.share()` method.
     */
    public func monitorList<D: DynamicObject>(_ from: From<D>, _ fetchClauses: [FetchClause]) -> Observable<RxListChange<D>> {
        
        return self.base.monitorList(from, fetchClauses).asObservable()
    }
    
    public func monitorSectionedList<D: DynamicObject>(_ from: From<D>, _ sectionBy: SectionBy, _ fetchClauses: FetchClause...) -> Observable<RxListChange<D>> {
        
        return self.monitorSectionedList(from, sectionBy, fetchClauses)
    }
    
    public func monitorSectionedList<D: DynamicObject>(_ from: From<D>, _ sectionBy: SectionBy, _ fetchClauses: [FetchClause]) -> Observable<RxListChange<D>> {
        
        return self.base.monitorSectionedList(from, sectionBy, fetchClauses).asObservable()
    }
