CloseableUtil.closeQuietly(in);
        logger.info(content);
        assertTrue(content.contains("テスト"));
    }

    public void test_getTika_hpp() {
        final InputStream in = ResourceUtil.getResourceAsStream("extractor/program/test.hpp");
        final ExtractData extractData = tikaExtractor.getText(in, null);
        final String content = extractData.getContent();

        try (final InputStream in = ResourceUtil.getResourceAsStream("extractor/eml/sample1.eml")) {
            ExtractData data = emlExtractor.getText(in, null);
            final String content = data.getContent();
            logger.info(content);
            assertTrue(content.contains("プレイステーション"));
            assertTrue(data.getValues("Subject")[0].contains("ダイジェスト"));
        }
    }

        return connection.getHeaderField(index);
    }

    @Override
    public Object getContent() throws IOException {
        try {
            handshake();
        } catch (final IOException ex) {}
        return connection.getContent();
    }

    @Override
    public Object getContent(final Class[] classes) throws IOException {
        try {
            handshake();

                final Parser parser = new TikaDetectParser();
                final ParseContext parseContext = createParseContext(parser, params);

                String content = getContent(writer -> {
                    InputStream in = null;
                    try {
                        if (!isByteStream) {
                            try (OutputStream out = new FileOutputStream(tempFile)) {

    /**
     * Gets the extracted content.
     *
     * @return the extracted content
     */
    public String getContent() {
        return content;
    }

    /**
     * Sets the extracted content.
     *
     * @param content the content to set
     */
    public void setContent(final String content) {
        this.content = content;
    }

    /**

	c.Assert(err, nil)
	c.Assert(response.StatusCode, http.StatusOK)
	// extract the content from response body.
	getContent, err := io.ReadAll(response.Body)
	c.Assert(err, nil)

	// Compare putContent and getContent.
	c.Assert(string(getContent), putContent)
}

// TestGetObjectLarge11MiB - Tests validate fetching of an object of size 11MB.

                .param("size", ComponentUtil.getFessConfig().getPageDictionaryMaxFetchSize())
                .execute()) {
            final Map<String, Object> contentMap = response.getContent(OpenSearchCurl.jsonParser());
            @SuppressWarnings("unchecked")
            final List<Map<String, Object>> fileList = (List<Map<String, Object>>) contentMap.get("file");

    }

    public void test_getText() {
        final InputStream in = ResourceUtil.getResourceAsStream("extractor/lha/test.lzh");
        final String content = lhaExtractor.getText(in, null).getContent();
        CloseableUtil.closeQuietly(in);
        logger.info(content);
        assertTrue(content.contains("テスト"));
        assertTrue(content.contains("テキスト"));
    }

    }

    @Override
    public Object getContent() throws IOException {
        handshake();
        return this.connection.getContent();
    }

    @Override
    public Object getContent(final Class[] classes) throws IOException {
        handshake();
        return this.connection.getContent(classes);
    }

    @Override

    }

    public void test_getText() {
        final InputStream in = ResourceUtil.getResourceAsStream("extractor/zip/test.zip");
        final String content = zipExtractor.getText(in, null).getContent();
        CloseableUtil.closeQuietly(in);
        logger.info(content);
        assertTrue(content.contains("テスト"));
        assertTrue(content.contains("テキスト"));
    }