Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 831 for Streams (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/main/java/org/codelibs/fess/helper/PopularWordHelper.java

                    stream(baseTags).of(stream -> stream.forEach(tag -> popularWordsRequestBuilder.addTag(tag)));
                    stream(baseRoles).of(stream -> stream.forEach(role -> popularWordsRequestBuilder.addRole(role)));
                    stream(baseFields).of(stream -> stream.forEach(field -> popularWordsRequestBuilder.addField(field)));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top