Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 71 for InputStream (0.06 seconds)

  1. src/test/java/org/codelibs/fess/util/InputStreamThreadTest.java

            assertTrue(output.contains("UTF-16 test"));
        }
    
        @Test
        public void test_run_withIOException() throws InterruptedException {
            InputStream faultyStream = new InputStream() {
                @Override
                public int read() throws IOException {
                    throw new IOException("Test exception");
                }
            };
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 12K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/fess/crawler/helper/FessMimeTypeHelperTest.java

                }
            });
    
            mimeTypeHelper.init();
    
            try (InputStream is = new ByteArrayInputStream(SQL_REM_CONTENT.getBytes(StandardCharsets.UTF_8))) {
                assertEquals("text/x-sql", mimeTypeHelper.getContentType(is, "test.sql"));
            }
            try (InputStream is = new ByteArrayInputStream(SQL_REM_CONTENT.getBytes(StandardCharsets.UTF_8))) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Jan 24 09:06:33 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/io/ByteStreamsTest.java

        byte[] big = newPreFilledByteArray(5);
        InputStream bin = new ByteArrayInputStream(big);
        InputStream lin = ByteStreams.limit(bin, 2);
    
        IOException expected = assertThrows(IOException.class, lin::reset);
        assertThat(expected).hasMessageThat().isEqualTo("Mark not set");
      }
    
      public void testLimit_markNotSupported() {
        InputStream lin = ByteStreams.limit(new UnmarkableInputStream(), 2);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 22K bytes
    - Click Count (0)
  4. .teamcity/scripts/CheckWrapper.java

        }
    
        private static Future<String> readStreamAsync(InputStream inputStream) {
            return THREAD_POOL.submit((Callable<String>) () -> readFully(inputStream));
        }
    
        private static String readFully(InputStream inputStream) throws IOException {
            try (InputStream input = inputStream; ByteArrayOutputStream out = new ByteArrayOutputStream()) {
                byte[] buf = new byte[8192];
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Jan 20 03:53:25 GMT 2026
    - 6.4K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/curl/io/ContentCache.java

     * try (ContentCache cache = new ContentCache(data)) {
     *     InputStream inputStream = cache.getInputStream();
     *     // Read from inputStream
     * }
     *
     * // File-based caching
     * File file = new File("example.txt");
     * try (ContentCache cache = new ContentCache(file)) {
     *     InputStream inputStream = cache.getInputStream();
     *     // Read from inputStream
     * }
     * }
     * </pre>
     *
     */
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 4.8K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/io/ByteStreamsTest.java

        byte[] big = newPreFilledByteArray(5);
        InputStream bin = new ByteArrayInputStream(big);
        InputStream lin = ByteStreams.limit(bin, 2);
    
        IOException expected = assertThrows(IOException.class, lin::reset);
        assertThat(expected).hasMessageThat().isEqualTo("Mark not set");
      }
    
      public void testLimit_markNotSupported() {
        InputStream lin = ByteStreams.limit(new UnmarkableInputStream(), 2);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 22K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/dict/stopwords/StopwordsFileTest.java

        }
    
        // Test reload with InputStream
        @Test
        public void test_reload_withComments() {
            String content = "# This is a comment\n" + "word1\n" + "\n" + // empty line
                    "word2\n" + "# Another comment\n" + "word3\n";
    
            InputStream is = new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 18K bytes
    - Click Count (0)
  8. .teamcity/scripts/CheckBadMerge.java

                .collect(Collectors.toList());
        }
    
        private static Future<String> readStreamAsync(InputStream inputStream) {
            return THREAD_POOL.submit((Callable<String>) () -> readFully(inputStream));
        }
    
        private static String readFully(InputStream inputStream) throws IOException {
            try (InputStream in = inputStream; ByteArrayOutputStream out = new ByteArrayOutputStream()) {
                byte[] buffer = new byte[8192];
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 30 16:25:09 GMT 2026
    - 9K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/util/JobProcessTest.java

            private final InputStream inputStream;
    
            public MockProcess(String output) {
                this.inputStream = new ByteArrayInputStream(output.getBytes());
            }
    
            @Override
            public OutputStream getOutputStream() {
                return null;
            }
    
            @Override
            public InputStream getInputStream() {
                return inputStream;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/curl/io/ContentCacheTest.java

            // First read
            try (InputStream stream1 = cache.getInputStream()) {
                byte[] buffer1 = new byte[1024];
                int bytesRead1 = stream1.read(buffer1);
                assertEquals(testContent, new String(buffer1, 0, bytesRead1, "UTF-8"));
            }
    
            // Second read - should work independently
            try (InputStream stream2 = cache.getInputStream()) {
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 09:11:12 GMT 2026
    - 15.9K bytes
    - Click Count (0)
Back to Top