documentReplications abstract method
Returns a Stream to be notified of DocumentReplications performed by
this replicator.
This is an alternative stream based API for the addDocumentReplicationListener API.
Because of performance optimization in the replicator, document replications need to be listened to before starting the replicator. If the listener is added after the replicator is started, the replicator needs to be stopped and restarted again to ensure that the listener will get the document replication events.
AsyncListenStream
If the stream is missing changes, check if the returned stream is an AsyncListenStream. This type of stream needs to perform some async work to be fully listening. You can wait for that moment by awaiting AsyncListenStream.listening.
Implementation
Stream<DocumentReplication> documentReplications();