Class BucketFlusher


  • @Uncommitted
    @Private
    public class BucketFlusher
    extends Object
    Helper class to flush a bucket properly and wait for it to be completed.
    Since:
    2.1.1
    Author:
    Michael Nitschinger
    • Method Detail

      • flush

        public static rx.Observable<Boolean> flush​(ClusterFacade core,
                                                   String bucket,
                                                   String password)
        Flush the bucket and make sure flush is complete before completing the observable.
        Parameters:
        core - the core reference.
        bucket - the bucket to flush.
        password - the password of the bucket.
        Returns:
        an observable which is completed once the flush process is done.
      • flush

        public static rx.Observable<Boolean> flush​(ClusterFacade core,
                                                   String bucket,
                                                   String username,
                                                   String password)
        Flush the bucket and make sure flush is complete before completing the observable.
        Parameters:
        core - the core reference.
        bucket - the bucket to flush.
        username - the user authorized for the bucket.
        password - the password of the user.
        Returns:
        an observable which is completed once the flush process is done.