Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for markSupported (0.16 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java

         * This method delegates to {@link FileInputStream#markSupported()}.
         *
         * @return {@code true} if this stream type supports the mark and reset method; {@code false} otherwise
         */
        @Override
        public boolean markSupported() {
            return fileInputStream.markSupported();
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java

         *
         * @return true if this stream instance supports the mark and reset methods; false otherwise
         */
        @Override
        public boolean markSupported() {
            return inputStream.markSupported();
        }
    
        /**
         * Reads the next byte of data from the input stream.
         *
         * @return the next byte of data, or -1 if the end of the stream is reached
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ZipExtractor.java

            final StringBuilder buf = new StringBuilder(1000);
    
            try (final ArchiveInputStream ais =
                    archiveStreamFactory.createArchiveInputStream(in.markSupported() ? in : new BufferedInputStream(in))) {
                ZipArchiveEntry entry = null;
                long contentSize = 0;
                while ((entry = (ZipArchiveEntry) ais.getNextEntry()) != null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/hash/HashingInputStream.java

        }
        return numOfBytesRead;
      }
    
      /**
       * mark() is not supported for HashingInputStream
       *
       * @return {@code false} always
       */
      @Override
      public boolean markSupported() {
        return false;
      }
    
      /** mark() is not supported for HashingInputStream */
      @Override
      public void mark(int readlimit) {}
    
      /**
       * reset() is not supported for HashingInputStream.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java

        ByteSource source = newByteSource(0, 10);
        ByteSource joined = ByteSource.concat(source, source);
        assertEquals(20, joined.size());
        InputStream in = joined.openStream();
        assertFalse(in.markSupported());
        assertEquals(10, in.available());
        int total = 0;
        while (in.read() != -1) {
          total++;
        }
        assertEquals(0, in.available());
        assertEquals(20, total);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/MultiInputStream.java

        }
      }
    
      @Override
      public int available() throws IOException {
        if (in == null) {
          return 0;
        }
        return in.available();
      }
    
      @Override
      public boolean markSupported() {
        return false;
      }
    
      @Override
      public int read() throws IOException {
        while (in != null) {
          int result = in.read();
          if (result != -1) {
            return result;
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/MultiInputStreamTest.java

        ByteSource source = newByteSource(0, 10);
        ByteSource joined = ByteSource.concat(source, source);
        assertEquals(20, joined.size());
        InputStream in = joined.openStream();
        assertFalse(in.markSupported());
        assertEquals(10, in.available());
        int total = 0;
        while (in.read() != -1) {
          total++;
        }
        assertEquals(0, in.available());
        assertEquals(20, total);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/MimeTypeHelperImpl.java

                        return mediaType.getType() + "/" + mediaType.getSubtype();
                    }
                }
    
                final MediaType mediaType = mimeTypes.detect(is == null || is.markSupported() ? is : new BufferedInputStream(is), metadata);
                if (useFilenameOnOctetStream && MediaType.OCTET_STREAM.equals(mediaType)) {
                    final MediaType mediaTypeFromFilename = mimeTypes.detect(null, metadata);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/CharSequenceReaderTest.java

      }
    
      public void testMarkAndReset() throws IOException {
        String string = "abcdefghijklmnopqrstuvwxyz";
        CharSequenceReader reader = new CharSequenceReader(string);
        assertTrue(reader.markSupported());
    
        assertEquals(string, readFully(reader));
        assertFullyRead(reader);
    
        // reset and read again
        reader.reset();
        assertEquals(string, readFully(reader));
        assertFullyRead(reader);
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/ByteStreams.java

          if (result != -1) {
            left -= result;
          }
          return result;
        }
    
        @Override
        public synchronized void reset() throws IOException {
          if (!in.markSupported()) {
            throw new IOException("Mark not supported");
          }
          if (mark == -1) {
            throw new IOException("Mark not set");
          }
    
          in.reset();
          left = mark;
        }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
Back to top