public interface IDatabaseChanges extends IConnectableChanges
Modifier and Type | Method and Description |
---|---|
IObservable<DocumentChangeNotification> |
forAllDocuments() |
IObservable<IndexChangeNotification> |
forAllIndexes() |
IObservable<ReplicationConflictNotification> |
forAllReplicationConflicts() |
IObservable<TransformerChangeNotification> |
forAllTransformers() |
IObservable<BulkInsertChangeNotification> |
forBulkInsert(java.util.UUID operationId) |
IObservable<DocumentChangeNotification> |
forDocument(java.lang.String docId) |
IObservable<DocumentChangeNotification> |
forDocumentsInCollection(java.lang.Class<?> clazz) |
IObservable<DocumentChangeNotification> |
forDocumentsInCollection(java.lang.String collectionName) |
IObservable<DocumentChangeNotification> |
forDocumentsOfType(java.lang.Class<?> clazz) |
IObservable<DocumentChangeNotification> |
forDocumentsOfType(java.lang.String typeName) |
IObservable<DocumentChangeNotification> |
forDocumentsStartingWith(java.lang.String docIdPrefix) |
IObservable<IndexChangeNotification> |
forIndex(java.lang.String indexName) |
addConnectionStatusChanged, isConnected, removeConnectionStatusChanges, waitForAllPendingSubscriptions
IObservable<IndexChangeNotification> forIndex(java.lang.String indexName)
IObservable<DocumentChangeNotification> forDocument(java.lang.String docId)
IObservable<DocumentChangeNotification> forAllDocuments()
IObservable<IndexChangeNotification> forAllIndexes()
IObservable<TransformerChangeNotification> forAllTransformers()
IObservable<DocumentChangeNotification> forDocumentsStartingWith(java.lang.String docIdPrefix)
IObservable<DocumentChangeNotification> forDocumentsInCollection(java.lang.String collectionName)
IObservable<DocumentChangeNotification> forDocumentsInCollection(java.lang.Class<?> clazz)
IObservable<DocumentChangeNotification> forDocumentsOfType(java.lang.String typeName)
IObservable<DocumentChangeNotification> forDocumentsOfType(java.lang.Class<?> clazz)
IObservable<ReplicationConflictNotification> forAllReplicationConflicts()
IObservable<BulkInsertChangeNotification> forBulkInsert(java.util.UUID operationId)
Copyright © 2014. All Rights Reserved.