Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 771 for Streams (0.03 sec)

  1. src/main/java/org/codelibs/fess/app/web/api/admin/dict/mapping/ApiAdminDictMappingAction.java

    import static org.codelibs.fess.app.web.admin.dict.mapping.AdminDictMappingAction.createCharMappingItem;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.CharMappingPager;
    import org.codelibs.fess.app.service.CharMappingService;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/dict/stemmeroverride/StemmerOverrideFile.java

            }
        }
    
        /**
         * Reloads the stemmer override dictionary from an input stream.
         *
         * @param updater An optional updater to apply changes.
         * @param in      The input stream to read the dictionary from.
         * @throws DictionaryException if the input stream cannot be parsed.
         */
        protected void reload(final StemmerOverrideUpdater updater, final InputStream in) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/app/web/api/admin/dict/synonym/ApiAdminDictSynonymAction.java

    import static org.codelibs.fess.app.web.admin.dict.synonym.AdminDictSynonymAction.createSynonymItem;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.SynonymPager;
    import org.codelibs.fess.app.service.SynonymService;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  4. src/test/java/jcifs/netbios/SessionServicePacketTest.java

    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/query/QueryCommand.java

            }
            final float importantContantLangBoost = fessConfig.getQueryBoostImportantContentLangAsDecimal().floatValue();
            getQueryLanguages().ifPresent(langs -> stream(langs).of(stream -> stream.forEach(lang -> {
                defaultQuery.add(
                        builder.apply(fessConfig.getIndexFieldTitle() + "_" + lang, fessConfig.getQueryBoostTitleLangAsDecimal().floatValue()));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/util/DocMapTest.java

            docMap.put("banana", "value3");
    
            Set<Map.Entry<String, Object>> entrySet = docMap.entrySet();
            assertEquals(4, entrySet.size());
    
            String[] keys = entrySet.stream().map(Map.Entry::getKey).toArray(String[]::new);
    
            boolean langFirst = "lang".equals(keys[0]);
            assertTrue("lang should be first or sorted normally", langFirst || Arrays.asList(keys).contains("lang"));
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/SecurityBlobTest.java

    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    
    import java.lang.reflect.Field;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    import org.junit.jupiter.params.ParameterizedTest;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  8. src/test/java/jcifs/netbios/SessionRequestPacketTest.java

    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.mockito.Mockito.when;
    
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/SearchHelper.java

                final String requiredKeysStr = fessConfig.getCookieSearchParameterRequiredKeys();
                if (StringUtil.isNotBlank(requiredKeysStr) && StreamUtil.split(requiredKeysStr, ",")
                        .get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).anyMatch(name -> {
                            final String[] values = req.getParameterValues(name);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 35.8K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb1/com/SmbComSeekResponseTest.java

         * Provides test cases for {@link SmbComSeekResponse#readParameterWordsWireFormat(byte[], int)}.
         * @return a stream of {@link Arguments} objects containing an integer
         *         value and the corresponding little-endian byte array.
         */
        static java.util.stream.Stream<Arguments> int32Provider() {
            return java.util.stream.Stream.of(Arguments.of(0x00000000, new byte[] { 0x00, 0x00, 0x00, 0x00 }),
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.1K bytes
    - Viewed (0)
Back to top