final byte[] buf = new byte[1024];
            int length;
            while (-1 < (length = in.read(buf))) {
                out.write(buf, 0, length);
                out.flush();
            }
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

    /**
     * Returns whether SIDs (Security Identifiers) should be resolved.

            final BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(dfos, enc));
            out.accept(writer);
            writer.flush();

            if (!dfos.isInMemory()) {
                tempFile = dfos.getFile();
            }

            try (Reader reader = new InputStreamReader(getContentStream(dfos), enc)) {

        try (DeferredFileOutputStream out = new DeferredFileOutputStream(cacheFileSize, "fess-extractor-", ".out", null)) {
            dfos = out;
            CopyUtil.copy(in, out);
            out.flush();

            Extractor extractor = StringUtil.isBlank(mimeType) ? null : extractorFactory.getExtractor(mimeType);
            if (extractor == null) {
                final String detectedMimeType = getMimeType(out);

            }
            if (!exceptionSet.isEmpty()) {
                throw exceptionSet.iterator().next();
            }
            writer.flush();
            final ExtractData extractData = new ExtractData(writer.toString());
            extractMetadata(document, extractData);
            return extractData;
        } catch (final Exception e) {

        final String actualIndex = index + "." + type.toLowerCase(Locale.ENGLISH);
        try {
            final XContentBuilder builder = JsonXContent.contentBuilder().map(source);
            builder.flush();
            client.prepareUpdate()
                    .setIndex(actualIndex)
                    .setId(id)
                    .setDocAsUpsert(true)
                    .setDoc(builder)

            logger.debug("Set suggest settings. {} {}", settingsIndexName, map.toString());
        }
        try {
            final XContentBuilder builder = JsonXContent.contentBuilder().map(map);
            builder.flush();
            client.prepareUpdate()
                    .setIndex(settingsIndexName)
                    .setId(settingsId)
                    .setDocAsUpsert(true)
                    .setDoc(builder)

    private static OutputStream getXContentOutputStream(final Map<String, Object> firstLineMap) throws IOException {
        try (XContentBuilder builder = JsonXContent.contentBuilder().map(firstLineMap)) {
            builder.flush();
            return builder.getOutputStream();
        }
    }

    /**
     * Creates a default ReadingConverter with a chain of converters.

            final byte[] buf = new byte[1024];
            int length;
            while (-1 < (length = in.read(buf))) {
                out.write(buf, 0, length);
                out.flush();
            }
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

    /**
     * Returns whether SIDs (Security Identifiers) should be resolved.

     */
    protected XContentBuilder getXContentBuilder(final Object target) {
        try {
            final XContentBuilder builder = jsonBuilder().value(target);
            builder.flush();
            return builder;
        } catch (final IOException e) {
            throw new OpenSearchAccessException("Failed to convert " + target + " to JSON.", e);
        }
    }

    /**

                        .setDirectory(SystemUtils.getJavaIoTmpDir())
                        .get()) {
                    CopyUtil.copy(responseBodyStream, dfos);
                    dfos.flush();

                    if (dfos.isInMemory()) {
                        responseData.setResponseBody(dfos.getData());
                        contentLength = dfos.getData().length;