- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for markSupported (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
server.enqueue(builder.build()) server.enqueue(builder.build()) val inputStream = getResponse(newRequest("/")).body.byteStream() assertThat(inputStream.markSupported(), "This implementation claims to support mark().") .isFalse() inputStream.mark(5) assertThat(readAscii(inputStream, 5)).isEqualTo("ABCDE") assertFailsWith<IOException> {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 21 20:36:35 UTC 2025 - 133.2K bytes - Viewed (0)