Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 409 for asStream (4.6 sec)

  1. src/main/java/org/codelibs/fess/helper/NotificationHelper.java

            if (StringUtil.isBlank(slackWebhookUrls)) {
                return;
            }
            final String body = toSlackMessage(discloser);
            StreamUtil.split(slackWebhookUrls, "[,\\s]").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(url -> {
                try (CurlResponse response = Curl.post(url).header("Content-Type", "application/json").body(body).execute()) {
                    if (response.getHttpStatusCode() == 200) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/service/GroupService.java

            });
    
            userBhv.selectCursor(cb -> cb.query().setGroups_Equal(group.getId()), entity -> {
                entity.setGroups(
                        stream(entity.getGroups()).get(stream -> stream.filter(s -> !s.equals(group.getId())).toArray(n -> new String[n])));
                userBhv.insertOrUpdate(entity);
            });
    
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/entity/GeoInfo.java

            final String[] geoFields = fessConfig.getQueryGeoFieldsAsArray();
            final Map<String, List<QueryBuilder>> geoMap = new HashMap<>();
    
            StreamUtil.stream(request.getParameterMap())
                    .of(stream -> stream.filter(e -> e.getKey().startsWith("geo.") && e.getKey().endsWith(".point")).forEach(e -> {
                        final String key = e.getKey();
                        for (final String geoField : geoFields) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/ldap/LdapManager.java

                                }
                            });
                            final List<String> newGroupList = stream(user.getGroupNames()).get(stream -> stream.collect(Collectors.toList()));
                            stream(user.getGroupNames()).of(stream -> stream.forEach(name -> {
                                if (oldGroupList.contains(name)) {
                                    oldGroupList.remove(name);
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 86.3K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb/CredentialsInternalTest.java

    import static org.mockito.Mockito.lenient;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verifyNoMoreInteractions;
    
    import java.util.stream.Stream;
    
    import javax.security.auth.Subject;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/core/stream/StreamUtilTest.java

            });
        }
    
        public void test_ofNull() {
            assertEquals(0, (int) StreamUtil.stream().get(s -> s.toArray().length));
            Object[] o = {};
            assertEquals(0, (int) StreamUtil.stream(o).get(s -> s.toArray().length));
            Map<Object, Object> map = new HashMap<Object, Object>();
            assertEquals(0, (int) StreamUtil.stream(map).get(s -> s.toArray().length));
        }
    
        public void test_ofMap() {
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/Extractor.java

    /**
     * The Extractor interface defines methods for extracting text data from an input stream.
     * Implementations of this interface should provide the logic for extracting text and
     * optionally override the default weight value.
     */
    public interface Extractor {
    
        /**
         * Extracts text data from the given input stream.
         *
         * @param in the input stream to extract text from
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

                final String commandStr = stream(commands).get(stream -> stream.map(s -> {
                    if ("$PASSWORD".equals(s)) {
                        return "***MASKED***";
                    }
                    if ("$USERNAME".equals(s)) {
                        return username;
                    }
                    return s;
                }).collect(java.util.stream.Collectors.joining(" ")));
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.crawler;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.LinkedHashSet;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Dec 11 09:47:03 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/MimeTypeHelperImpl.java

            this.useFilename = useFilename;
        }
    
        /**
         * Sets whether to use the filename for MIME type detection when the stream is octet-stream.
         *
         * @param useFilenameOnOctetStream true to use the filename for MIME type detection when the stream is octet-stream; false otherwise.
         */
        public void setUseFilenameOnOctetStream(final boolean useFilenameOnOctetStream) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 6.6K bytes
    - Viewed (0)
Back to top