How to capture error while using CouchbaseAsyncCluster.openBucket call

Java SDK
1

I have the following code that creates Couchbase cluster and tried to open a bucket. The name given to the bucket is a wrong name. I want to capture the error since the bucket does not exist. Using java client version 2.7.6 and Java 11.

CouchbaseAsyncCluster cluster = 
CouchbaseAsyncCluster.create("localhost");
cluster.authenticate("Administrator", "password");
rx.Observable<AsyncBucket> bucket;
cluster.openBucket("wrongName")
        .doOnError(e -> System.out.println("error occurred"))
        .doOnNext(openbucket -> System.out.println("bucket opened"))
        .subscribe(openBucket -> System.out.println("subscription 
         complete")); 
System.out.println("done...");

The above code does not generate any error and no entry in log either. What is the best way to capture the error opening a bucket?

2

This question was also posted on Stack Overflow, and answered there: