ResponseProcessor proc = testRule.getResponseProcessor();

                            // Verify consistency
                            if (!"concurrentRule".equals(ruleId)) {
                                errorCount.incrementAndGet();
                            }
                            if (proc != processor) {
                                errorCount.incrementAndGet();

                        for (int j = 0; j < operationsPerThread; j++) {
                            // Read name
                            String name = testTransformer.getName();
                            if (!"concurrentName".equals(name)) {
                                errorCount.incrementAndGet();
                            }

                            // Occasionally change name (10% of threads)

                            ResultData resultData = transformer.transform(responseData);

                            if (resultData != null && "concurrentTransformer".equals(resultData.getTransformerName())) {
                                successCount.incrementAndGet();
                            }

                            // GetData operation

                }

                final String sid = scrollId;
                response = get(c -> c.prepareSearchScroll(sid).setScroll(scrollForDelete).execute());
                if (!scrollId.equals(response.getScrollId())) {
                    clearScroll(scrollId);
                }
                scrollId = response.getScrollId();
            }
        } finally {
            clearScroll(scrollId);

                }

                final String sid = scrollId;
                response = getClient().get(c -> c.prepareSearchScroll(sid).setScroll(new TimeValue(scrollTimeout)).execute());
                if (!scrollId.equals(response.getScrollId())) {
                    getClient().clearScroll(scrollId);
                }
                scrollId = response.getScrollId();
            }
        } finally {

                final int idx = contentType.indexOf(';');
                if (idx > 0) {
                    contentType = contentType.substring(0, idx);
                    if (APPLICATION_OCTET_STREAM.equals(contentType)) {
                        contentType = null;
                    }
                }
            }

            long contentLength = 0;
            String contentEncoding = Constants.UTF_8;