Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 211 for asStream (0.13 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/org/codelibs/fess/util/ParameterUtil.java

            final Pattern properyPattern = Pattern.compile(ComponentUtil.getFessConfig().getAppEncryptPropertyPattern());
            final PrimaryCipher cipher = ComponentUtil.getPrimaryCipher();
            ParameterUtil.parse(value).entrySet().stream().map(e -> {
                final String k = e.getKey();
                final String v = e.getValue();
                if (properyPattern.matcher(k).matches() && !v.startsWith(CIPHER_PREFIX)) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java

            if (StringUtil.isNotEmpty(contentType)) {
                curlRequest.header("Content-Type", contentType);
            }
    
            request.getParameterMap().entrySet().stream().forEach(entry -> {
                if (entry.getValue().length > 1) {
                    curlRequest.param(entry.getKey(), String.join(",", entry.getValue()));
                } else if (entry.getValue().length == 1) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:40 GMT 2026
    - 13.4K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/util/DocumentUtil.java

                if (clazz.isAssignableFrom(List.class)) {
                    return (T) value;
                }
                if (clazz.isAssignableFrom(String[].class)) {
                    return (T) ((List<?>) value).stream().filter(s -> s != null).map(Object::toString).toArray(n -> new String[n]);
                }
    
                if (((List<?>) value).isEmpty()) {
                    return null;
                }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  4. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AbstractGradleViolationRule.groovy

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package gradlebuild.binarycompatibility.rules
    
    import com.google.gson.Gson
    import com.google.gson.stream.JsonWriter
    import gradlebuild.binarycompatibility.AcceptedApiChange
    import gradlebuild.binarycompatibility.AcceptedApiChanges
    import gradlebuild.binarycompatibility.AcceptedViolationsProvider
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Jan 22 12:18:18 GMT 2026
    - 10K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/dict/stopwords/StopwordsFileTest.java

            stopwordsFile.reload(null, is);
    
            assertEquals(2, stopwordsFile.stopwordsItemList.size());
            // The content creates two lines: "word\n1" and "word\"
            assertTrue(stopwordsFile.stopwordsItemList.stream().anyMatch(item -> item.getInput().contains("word")));
        }
    
        // Test StopwordsUpdater inner class
        @Test
        public void test_updater_writeOldItem() {
            loadTestData();
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 18K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/helper/RelatedContentHelper.java

            });
        }
    
        @Override
        public int load() {
            final Map<String, Pair<Map<String, String>, List<Pair<Pattern, String>>>> relatedContentMap = new HashMap<>();
            getAvailableRelatedContentList().stream().forEach(entity -> {
                final String key = getHostKey(entity);
                Pair<Map<String, String>, List<Pair<Pattern, String>>> pair = relatedContentMap.get(key);
                if (pair == null) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/chat/ChatClient.java

    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.LinkedHashMap;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.fess.entity.ChatMessage;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 56.6K bytes
    - Click Count (0)
  8. src/main/webapp/js/chat.js

    /**
     * Fess RAG Chat JavaScript
     * Enhanced with Atlassian Design System patterns
     */
    var FessChat = (function() {
        'use strict';
    
        var config = {
            apiUrl: '/api/v1/chat',
            streamUrl: '/api/v1/chat/stream',
            labels: {
                thinking: 'Thinking...',
                waiting: '...',
                error: 'An error occurred. Please try again.',
                sources: 'Sources',
                statusReady: 'AI Assistant',
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 19 01:36:02 GMT 2026
    - 30.6K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/it/admin/JobLogTests.java

            response = checkMethodBase(searchBody).get(API_PATH + "/logs").asString();
            List<Map<String, Object>> afterLogs = JsonPath.from(response).getList("response.logs");
    
            boolean logDeleted = afterLogs.stream().noneMatch(log -> logId.equals(log.get("id").toString()));
            assertTrue(logDeleted, "Log should be deleted");
    
            logger.info("[END] testDeleteJobLog");
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 21 13:29:45 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  10. src/main/webapp/WEB-INF/view/chat/chat.jsp

    	<script type="text/javascript" src="${fe:url('/js/chat.js')}"></script>
    	<script type="text/javascript">
    		$(function() {
    			FessChat.init({
    				apiUrl: '${fe:url('/api/v1/chat')}',
    				streamUrl: '${fe:url('/api/v1/chat/stream')}',
    				labels: {
    					thinking: '<la:message key="labels.chat_thinking" />',
    					waiting: '<la:message key="labels.chat_waiting" />',
    					error: '<la:message key="labels.chat_error" />',
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 19 01:36:02 GMT 2026
    - 10.8K bytes
    - Click Count (0)
Back to Top