})
.map(new Func1<ClusterConfig, CloseBucketResponse>() {
@Override
public CloseBucketResponse call(ClusterConfig clusterConfig) {
if (!clusterConfig.hasBucket(request.bucket())) {
return new CloseBucketResponse(ResponseStatus.SUCCESS);
}
throw new CouchbaseException("Could not close bucket.");
}
})
.subscribe(request.observable());