gistfile1.java

        queryTemplate = ViewQuery.from("design", "view");
        processViewOptions(queryTemplate, vopts.getInner());

        long iterRemaining = getPrivopts().iterCount;

        while (isCancelled == false) {
            boolean gotException = false;
            long beginTime = System.currentTimeMillis();

            String curView;
            try {
                curView = queryTemplate.getView();
                Observable<ViewResult> vresp = sdkHandle.query(queryTemplate);
                
                while (vresp.toBlocking().getIterator().hasNext()) {
                    ViewResult res = vresp.toBlocking().single();
                    CommandResult cmdres = new CommandResult(res.totalRows());
                    updateStats(cmdres);
                    doThinkTime();
                }
            }