Package 

Class CommonFlowsKt

    • Method Summary

      Modifier and Type Method Description
      final static <ERROR CLASS> collectionChangeFlow(Collection $self, Executor executor) A Flow of Collection changes.
      final static <ERROR CLASS> documentChangeFlow(Collection $self, String documentId, Executor executor) A Flow of document changes.
      final static <ERROR CLASS> documentChangeFlow(Database $self, String documentId, Executor executor) A Flow of document changes.
      final static <ERROR CLASS> replicatorChangesFlow(Replicator $self, Executor executor) A Flow of replicator state changes.
      final static <ERROR CLASS> documentReplicationFlow(Replicator $self, Executor executor) A Flow of document replications.
      final static <ERROR CLASS> queryChangeFlow(Query $self, Executor executor) A Flow of query changes.
      final static <ERROR CLASS> 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 <ERROR CLASS> collectionChangeFlow(Collection $self, Executor executor)

        A Flow of Collection changes.

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

      • documentChangeFlow

         final static <ERROR CLASS> 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 <ERROR CLASS> 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 <ERROR CLASS> 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 <ERROR CLASS> 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 <ERROR CLASS> 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 <ERROR CLASS> databaseChangeFlow(Database $self, Executor executor)

        A Flow of database changes.

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