Package 

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.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • collectionChangeFlow

         final static Flow<CollectionChange> collectionChangeFlow(Collection $self, Executor executor)

        A Flow of Collection changes.

        Parameters:
        executor - The executor on which to run the change listener (Should be nullable?

      • 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: default is the default executor

      • documentChangeFlow

        @Deprecated(message = Use getCollection(String, String?).documentChangeFlow(documentId, executor), replaceWith = @ReplaceWith(imports = {}, expression = 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: default is the default executor

      • 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: default is the default executor

      • documentReplicationFlow

         final static Flow<DocumentReplication> documentReplicationFlow(Replicator $self, Executor executor)

        A Flow of document replications.

        Parameters:
        executor - Optional executor on which to run the change listener: default is the default executor

      • 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: default is the default executor

      • databaseChangeFlow

        @Deprecated(message = Use getCollection(String, String?).collectionChangeFlow(executor), replaceWith = @ReplaceWith(imports = {}, expression = 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: default is the default executor