- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 831 for Streams (0.06 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MimeTypeHelper.java
/** * MimeTypeHelper provides methods to determine the content type of a given input stream or file. * It allows content type detection based on the stream's content and/or filename. */ public interface MimeTypeHelper { /** * Determines the content type of the given input stream and filename. * @param is the input stream to analyze * @param filename the filename to help determine the content type
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 1.6K bytes - Viewed (0) -
cmd/testdata/xl-meta-consist.zip
¼X-Minio-Internal-actual-sizeÄ 141250§MetaUsr‚¬content-type¸application/octet-stream¤etagÙ"51fe09d68bacc8c5a68a-1Îsç¦> 5/xl.meta XL2 Æ ‚ Ä$•Ä Ó ¿W '’žÉÄ «Iå Å V‚¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ÔLã°ê8EÒŸˆ”Ù Sé6¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistš ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ò 'ªPartASizes‘Ò '¤SizeÒ 'Â¥MTimeÓ ¿W '’žÉ§MetaSys ¼X-Minio-Internal-actual-sizeÄ 141250§MetaUsr‚¤etagÙ"51fe09d68bacc8c5a68a-1¬content-type¸application/octet-streamÎ-ú^ 6/xl.meta XL2 Æ b ¨Versions‘‚¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ÔLã°ê8EÒŸˆ”Ù...
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Jan 19 18:48:00 UTC 2022 - 4.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/converter/KatakanaConverter.java
try (TokenStream stream = createTokenStream(rd)) { if (stream == null) { throw new IOException("Invalid tokenizer."); } stream.reset(); int offset = 0; while (stream.incrementToken()) { final CharTermAttribute att = stream.getAttribute(CharTermAttribute.class);
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 6.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.22.md
- SSA treats certain structs as atomic ([#100684](https://github.com/kubernetes/kubernetes/pull/100684), [@Jefftree](https://github.com/Jefftree)) [SIG API Machinery, Auth, Node and Storage]
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Tue Dec 13 12:43:45 UTC 2022 - 454.1K bytes - Viewed (0) -
guava/src/com/google/common/collect/Comparators.java
* * <p>For example: * * {@snippet : * Stream.of("foo", "quux", "banana", "elephant") * .collect(least(2, comparingInt(String::length))) * // returns {"foo", "quux"} * } * * <p>This {@code Collector} uses O(k) memory and takes expected time O(n) (worst-case O(n log * k)), as opposed to e.g. {@code Stream.sorted(comparator).limit(k)}, which currently takes O(n
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 10.9K bytes - Viewed (0) -
src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java
assertThrows(IOException.class, () -> sis.read()); } @Test @DisplayName("Available returns underlying stream available when no message buffered") void availableReturnsUnderlyingWhenNoMessage() throws IOException { // Mock input stream that reports available bytes InputStream mockIn = mock(InputStream.class); when(mockIn.available()).thenReturn(42);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/stream/StreamUtil.java
* Executes the provided {@link Consumer} with a {@link Stream} obtained from the supplier. * The stream is automatically closed after the consumer is executed. * * @param stream the {@link Consumer} to process the {@link Stream} */ public void of(final Consumer<Stream<T>> stream) { try (Stream<T> s = supplier.get()) { stream.accept(s); } }
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/PopularWordHelper.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 7.3K bytes - Viewed (0) -
docs/de/docs/advanced/custom-response.md
{* ../../docs_src/custom_response/tutorial006c.py hl[2,7,9] *} ### `StreamingResponse` Nimmt einen asynchronen Generator oder einen normalen Generator/Iterator und streamt den Responsebody. {* ../../docs_src/custom_response/tutorial007.py hl[2,14] *} #### Verwendung von `StreamingResponse` mit dateiähnlichen Objekten
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 13.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
} return list.stream().map(p -> { final String key = p.getFirst(); if (StringUtil.isEmpty(key) || userBean .map(user -> stream(user.getRoles()).get(stream -> stream.anyMatch(s -> (ROLE_VALUE_PREFIX + s).equals(key))) || stream(user.getGroups()).get(stream -> stream.anyMatch(s -> (GROUP_VALUE_PREFIX + s).equals(key))))
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 86.5K bytes - Viewed (0)