Class CommonFlowsKt

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
    • Field Summary

      Fields 
      Modifier and Type Field Description
    • Constructor Summary

      Constructors 
      Constructor Description
    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description
    • 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<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.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

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