Details
Description
If you try to run a simple query view twice at beta, you will notice that only #1 attempt will work, the second will wait indefinitely.
In beta-2, the query won't work at all, it will block right away!!
I've tested with async and sync mode in both releases.
Could you please take a look on that?
Thanks.
@Test
public void testAsync() throws Exception {
CouchbaseCluster cluster = CouchbaseCluster.create(DefaultCouchbaseEnvironment.builder().build());
Bucket bucket = cluster.openBucket("default");
CountDownLatch latch = new CountDownLatch(10);
for (int i = 0; i < 10; i++) {
bucket
.async()
.query(ViewQuery.from("test", "test"))
.doOnNext(result -> {
if (!result.success())
})
.flatMap(AsyncViewResult::rows)
.subscribe(row ->
);
}
latch.await();
}