.setScroll(settings.getScrollTimeout())
                            .execute()
                            .actionGet(settings.getSearchTimeout());
                    if (!scrollId.equals(response.getScrollId())) {
                        SuggestUtil.deleteScrollContext(client, scrollId);
                    }
                    scrollId = response.getScrollId();
                }
            } finally {

            if (skipDuplicateWords) {
                final String duplicateCheckStr = text.replace(" ", "");
                if (words.stream().map(word -> word.replace(" ", "")).anyMatch(word -> word.equals(duplicateCheckStr))) {
                    // skip duplicate word.
                    continue;
                }
            }

            words.add(text);

                            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)

        assertTrue(dest.contains("new1"));
        assertTrue(dest.contains("new2"));
        // Should not have duplicate "existing"
        assertEquals(1, dest.stream().filter(s -> s.equals("existing")).count());
    }

    @Test
    public void testConcatKinds() {
        // Test static concatKinds method
        SuggestItem.Kind[] kinds1 = { SuggestItem.Kind.QUERY };

                            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 {

                    break;
                }
                response = suggester.popularWords().setSize(2).addExcludeWord(excludeWord).execute().getResponse();
            }
            if (checkStr.equals(excludeWord)) {
                assertFalse(find);
            } else {
                assertTrue(find);
            }
        }
    }

    @Test
    public void test_escapeQuery() throws Exception {

                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;