io.vertx.rx.java.ObservableFuture<JsonObject> resultHandler = io.vertx.rx.java.RxHelper.observableFuture();
distinctBatch(collection, fieldName, resultClassname, resultHandler.toHandler());
return resultHandler;
}
public void close() {
<BUG>this.delegate.close();
}</BUG>
public static MongoClient newInstance(io.vertx.ext.mongo.MongoClient arg) {
return arg != null ? new MongoClient(arg) : null;
}

io.vertx.rx.java.ObservableFuture<JsonObject> resultHandler = io.vertx.rx.java.RxHelper.observableFuture();
distinctBatch(collection, fieldName, resultClassname, resultHandler.toHandler());
return resultHandler;
}
public void close() {
delegate.close();
}
public static MongoClient newInstance(io.vertx.ext.mongo.MongoClient arg) {
return arg != null ? new MongoClient(arg) : null;
