Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 59 for InputStream (0.13 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. .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)
  6. 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)
  7. 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)
  8. android/guava/src/com/google/common/io/ByteStreams.java

      }
    
      /**
       * Wraps a {@link InputStream}, limiting the number of bytes which can be read.
       *
       * @param in the input stream to be wrapped
       * @param limit the maximum number of bytes to be read
       * @return a length-limited {@link InputStream}
       * @since 14.0 (since 1.0 as com.google.common.io.LimitInputStream)
       */
      @J2ktIncompatible
      public static InputStream limit(InputStream in, long limit) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 31.1K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/curl/io/IOIntegrationTest.java

            public String getRequestMethod() {
                return "HEAD";
            }
    
            @Override
            public InputStream getInputStream() {
                throw new AssertionError("HEAD request should not read input stream");
            }
    
            @Override
            public InputStream getErrorStream() {
                throw new AssertionError("HEAD request should not read error stream");
            }
    
            @Override
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 12:00:34 GMT 2026
    - 44.1K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/webapp/WebXmlTest.java

            factory.setNamespaceAware(true);
            final DocumentBuilder builder = factory.newDocumentBuilder();
            try (InputStream is = getClass().getClassLoader().getResourceAsStream("../webapp/WEB-INF/web.xml")) {
                if (is == null) {
                    try (InputStream is2 = Thread.currentThread().getContextClassLoader().getResourceAsStream("web.xml")) {
                        if (is2 != null) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 09:08:35 GMT 2026
    - 3.1K bytes
    - Click Count (0)
Back to Top