Package com.couchbase.client.java.bucket
Class BucketFlusher
- java.lang.Object
-
- com.couchbase.client.java.bucket.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 Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static rx.Observable<Boolean>
flush(ClusterFacade core, String bucket, String password)
Flush the bucket and make sure flush is complete before completing the observable.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.
-
-
-
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.
-
-