nonNull(request, "request");
        Reader reader = request.getReader();
        InputStream inputStream = request.getInputStream();
        if (reader == null && inputStream == null) {
            throw new IllegalArgumentException("reader or inputStream must be non null");
        }
        try {
            InputSource source = null;

    public void test_getHtml_utf8() {
        final InputStream in = ResourceUtil.getResourceAsStream("extractor/test_utf8.html");
        final String content = htmlXpathExtractor.getText(in, null).getContent();
        CloseableUtil.closeQuietly(in);
        logger.info(content);
        assertTrue(content.contains("テスト"));
    }

    public void test_getHtml_sjis() {

        @Override
        public <T> T withInputStream(IoFunction<InputStream, T> action) throws IOException {
            InputStream inputStream = getInputStream();
            try {
                return action.apply(inputStream);
            } finally {
                inputStream.close();
            }
        }

        private InputStream getInputStream() {
            try {

        URL url = request.getURL();
        Reader reader = request.getReader();
        InputStream inputStream = request.getInputStream();
        if (path == null && url == null && reader == null && inputStream == null) {
            throw new IllegalArgumentException("path, url, reader or inputStream must be non null");
        }
        try {
            InputSource source = null;

import java.io.InputStream
import java.io.OutputStream


private
enum class StreamReference {
    IN, OUT, ERR, UNSUPPORTED
}


object InputStreamCodec : Codec<InputStream> {
    override suspend fun WriteContext.encode(value: InputStream) {
        if (value !== System.`in`) {
            logUnsupportedBaseType("serialize", InputStream::class, unpackType(value), appendix = supportedStreamsInfo())

        def process = ['ar', '-t', binaryFile.getAbsolutePath()].execute(environments, null)
        return process.inputStream.readLines().drop(1)
    }

    List<String> listLinkedLibraries() {
        def process = ['otool', '-L', binaryFile.absolutePath].execute(environments, null)
        def lines = process.inputStream.readLines()
        return lines
    }

    List<Symbol> listSymbols() {

    /*
     * (non-Javadoc)
     *
     * @see org.codelibs.fess.crawler.extractor.Extractor#getText(java.io.InputStream,
     * java.util.Map)
     */
    @Override
    public ExtractData getText(final InputStream in, final Map<String, String> params) {
        if (in == null) {
            throw new CrawlerSystemException("The inputstream is null.");
        }
        try {
            @SuppressWarnings("resource")

                }

                try ( InputStream is = f.getInputStream() ) {
                    verifyRandom(bufSize, length, is);
                }

            }
            finally {
                f.delete();
            }
        }
    }


    static void verifyRandom ( int bufSize, long length, InputStream is ) throws IOException {
        verifyRandom(bufSize, length, true, is);

        return null;
    }

    private byte[] loadBytecode(URL resource) throws IOException {
        InputStream inputStream = resource.openStream();
        try {
            return ByteStreams.toByteArray(inputStream);
        } finally {
            inputStream.close();
        }
    }

    protected boolean shouldTransform(String className) {
        return true;
    }

 * limitations under the License.
 */

package org.gradle.caching.internal.origin;

import java.io.IOException;
import java.io.InputStream;

public interface OriginReader {
    OriginMetadata execute(InputStream inputStream) throws IOException;