Package | Description |
---|---|
net.ravendb.client.changes | |
net.ravendb.client.connection | |
net.ravendb.client.connection.implementation | |
net.ravendb.client.document | |
net.ravendb.client.shard |
Modifier and Type | Class and Description |
---|---|
class |
TaskedObservable<T,TConnectionState extends IChangesConnectionState> |
Modifier and Type | Method and Description |
---|---|
IObservable<DataSubscriptionChangeNotification> |
RemoteDatabaseChanges.forAllDataSubscriptions() |
IObservable<DataSubscriptionChangeNotification> |
IDatabaseChanges.forAllDataSubscriptions()
Subscribe to changes for all data subscriptions.
|
IObservable<DocumentChangeNotification> |
RemoteDatabaseChanges.forAllDocuments() |
IObservable<DocumentChangeNotification> |
IDatabaseChanges.forAllDocuments()
Subscribe to changes for all documents.
|
IObservable<IndexChangeNotification> |
RemoteDatabaseChanges.forAllIndexes() |
IObservable<IndexChangeNotification> |
IDatabaseChanges.forAllIndexes()
Subscribe to changes for all indexes.
|
IObservable<ReplicationConflictNotification> |
RemoteDatabaseChanges.forAllReplicationConflicts() |
IObservable<ReplicationConflictNotification> |
IDatabaseChanges.forAllReplicationConflicts()
Subscribe to all replication conflicts.
|
IObservable<TransformerChangeNotification> |
RemoteDatabaseChanges.forAllTransformers() |
IObservable<TransformerChangeNotification> |
IDatabaseChanges.forAllTransformers()
Subscribe to changes for all transformers.
|
IObservable<BulkInsertChangeNotification> |
RemoteDatabaseChanges.forBulkInsert() |
IObservable<BulkInsertChangeNotification> |
IDatabaseChanges.forBulkInsert()
Subscribe to all bulk insert operation changes
|
IObservable<BulkInsertChangeNotification> |
RemoteDatabaseChanges.forBulkInsert(UUID operationId) |
IObservable<BulkInsertChangeNotification> |
IDatabaseChanges.forBulkInsert(UUID operationId)
Subscribe to all bulk insert operation changes that belong to a operation with given Id.
|
IObservable<DataSubscriptionChangeNotification> |
RemoteDatabaseChanges.forDataSubscription(long subscriptionId) |
IObservable<DataSubscriptionChangeNotification> |
IDatabaseChanges.forDataSubscription(long id)
Subscribe to changes for a specified data subscription.
|
IObservable<DocumentChangeNotification> |
RemoteDatabaseChanges.forDocument(String docId) |
IObservable<DocumentChangeNotification> |
IDatabaseChanges.forDocument(String docId)
Subscribe to changes for specified document only.
|
IObservable<DocumentChangeNotification> |
RemoteDatabaseChanges.forDocumentsInCollection(Class<?> clazz) |
IObservable<DocumentChangeNotification> |
IDatabaseChanges.forDocumentsInCollection(Class<?> clazz)
Subscribe to changes for all documents that belong to specified collection (Raven-Entity-Name).
|
IObservable<DocumentChangeNotification> |
RemoteDatabaseChanges.forDocumentsInCollection(String collectionName) |
IObservable<DocumentChangeNotification> |
IDatabaseChanges.forDocumentsInCollection(String collectionName)
Subscribe to changes for all documents that belong to specified collection (Raven-Entity-Name).
|
IObservable<DocumentChangeNotification> |
RemoteDatabaseChanges.forDocumentsOfType(Class<?> clazz) |
IObservable<DocumentChangeNotification> |
IDatabaseChanges.forDocumentsOfType(Class<?> clazz)
Subscribe to changes for all documents that belong to specified type (Raven-Clr-Type).
|
IObservable<DocumentChangeNotification> |
RemoteDatabaseChanges.forDocumentsOfType(String typeName) |
IObservable<DocumentChangeNotification> |
IDatabaseChanges.forDocumentsOfType(String typeName)
Subscribe to changes for all documents that belong to specified type (Raven-Clr-Type).
|
IObservable<DocumentChangeNotification> |
RemoteDatabaseChanges.forDocumentsStartingWith(String docIdPrefix) |
IObservable<DocumentChangeNotification> |
IDatabaseChanges.forDocumentsStartingWith(String docIdPrefix)
Subscribe to changes for all documents that Id starts with given prefix.
|
IObservable<IndexChangeNotification> |
RemoteDatabaseChanges.forIndex(String indexName) |
IObservable<IndexChangeNotification> |
IDatabaseChanges.forIndex(String indexName)
Subscribe to changes for specified index only.
|
IObservable<T> |
IObservable.where(Predicate<T> predicate) |
IObservable<T> |
TaskedObservable.where(Predicate<T> predicate) |
Modifier and Type | Class and Description |
---|---|
class |
ObservableLineStream |
Modifier and Type | Method and Description |
---|---|
IObservable<String> |
ObservableLineStream.where(Predicate<String> predicate) |
Modifier and Type | Method and Description |
---|---|
IObservable<String> |
HttpJsonRequest.serverPull() |
Modifier and Type | Class and Description |
---|---|
class |
Subscription<T> |
Modifier and Type | Method and Description |
---|---|
IObservable<T> |
Subscription.where(Predicate<T> predicate) |
Modifier and Type | Class and Description |
---|---|
class |
ShardedObservable<T> |
Constructor and Description |
---|
ShardedObservable(List<IObservable<T>> inner) |
Copyright © 2016. All Rights Reserved.