         return observingConnection
     }
 
-    public var databaseWriteSucceeded: Observable<Void> {
-        return transactionEnded
+    public var writeTransactionEnded: Observable<Void> {
+        return databaseWriteTransactionEnded
     }
 
     // MARK: Internal methods

    }

    func notifiyTransactionEnded(wasRolledBack wasRolledBack: Bool) {
        Dispatch.asynchronouslyOn(databaseTransactionEnded) {
            self.transactionEnded.handle(next: ())
        }
    }


    private var cacheUpdatesBySnapshot: [UInt64: [String: TypeErasedCacheUpdates]]
    private var minCacheUpdatesSnapshot: UInt64

    private let databaseWriteTransactionEnded: Subject<Void>
    private let databaseWriteTransactionEndedQueue: Dispatch.Queue

    private let databaseWriteQueue: Dispatch.Queue
    private let connectionSetUpQueue: Dispatch.Queue
