com.couchbase.client.java.bucket

Class BucketFlusher

java.lang.Object

com.couchbase.client.java.bucket.BucketFlusher

@InterfaceStability.Uncommitted
 @InterfaceAudience.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

Modifier and Type	Method and Description
static Observable<Boolean>	flush(ClusterFacade core, String bucket, String password) Flush the bucket and make sure flush is complete before completing the observable.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

flush

public static 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.