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 - 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

         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.

        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

         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.