Package com.couchbase.lite
Class CommonFlowsKt
-
- All Implemented Interfaces:
public final class CommonFlowsKt
-
-
Method Summary
Modifier and Type Method Description final static Flow<CollectionChange>
collectionChangeFlow(Collection $self, Executor executor)
A Flow of Collection changes. final static Flow<DocumentChange>
documentChangeFlow(Collection $self, String documentId, Executor executor)
A Flow of document changes. final static Flow<DocumentChange>
documentChangeFlow(Database $self, String documentId, Executor executor)
A Flow of document changes. final static Flow<ReplicatorChange>
replicatorChangesFlow(Replicator $self, Executor executor)
A Flow of replicator state changes. final static Flow<DocumentReplication>
documentReplicationFlow(Replicator $self, Executor executor)
A Flow of document replications. final static Flow<QueryChange>
queryChangeFlow(Query $self, Executor executor)
A Flow of query changes. final static Flow<DatabaseChange>
databaseChangeFlow(Database $self, Executor executor)
A Flow of database changes. -
-
Method Detail
-
collectionChangeFlow
final static Flow<CollectionChange> collectionChangeFlow(Collection $self, Executor executor)
A Flow of Collection changes.
- Parameters:
executor
- Optional executor on which to run the change listener.
-
documentChangeFlow
final static Flow<DocumentChange> documentChangeFlow(Collection $self, String documentId, Executor executor)
A Flow of document changes.
- Parameters:
executor
- Optional executor on which to run the change listener.
-
documentChangeFlow
@Deprecated(message = "Use Database.getCollection(String, String?).documentChangeFlow(documentId, executor)", replaceWith = @ReplaceWith(imports = {}, expression = "Database.getCollection(String, String?).documentChangeFlow(documentId, executor)")) final static Flow<DocumentChange> documentChangeFlow(Database $self, String documentId, Executor executor)
A Flow of document changes.
- Parameters:
executor
- Optional executor on which to run the change listener.
-
replicatorChangesFlow
final static Flow<ReplicatorChange> replicatorChangesFlow(Replicator $self, Executor executor)
A Flow of replicator state changes.
- Parameters:
executor
- Optional executor on which to run the change listener.
-
documentReplicationFlow
final static Flow<DocumentReplication> documentReplicationFlow(Replicator $self, Executor executor)
A Flow of document replications. This is a flow of DocumentReplications, each of which contains a list of ReplicatedDocuments, each of which, in turn, contains the name (String) of the document scope, the name (String) of the document collection, and the document ID (String).
- Parameters:
executor
- Optional executor on which to run the change listener.
-
queryChangeFlow
final static Flow<QueryChange> queryChangeFlow(Query $self, Executor executor)
A Flow of query changes.
- Parameters:
executor
- Optional executor on which to run the change listener.
-
databaseChangeFlow
@Deprecated(message = "Use Database.getCollection(String, String?).collectionChangeFlow(executor)", replaceWith = @ReplaceWith(imports = {}, expression = "Database.getCollection(String, String?).collectionChangeFlow(executor)")) final static Flow<DatabaseChange> databaseChangeFlow(Database $self, Executor executor)
A Flow of database changes.
- Parameters:
executor
- Optional executor on which to run the change listener.
-
-
-
-