Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 788 for streams (0.04 sec)

  1. src/main/java/org/codelibs/fess/app/web/search/SearchAction.java

                }
            }
            form.fields.entrySet().stream().filter(e -> e.getValue() != null).forEach(e -> {
                final String key = LaFunctions.u(e.getKey());
                stream(e.getValue()).of(stream -> stream.filter(StringUtil::isNotBlank)
                        .forEach(s -> pagingQueryList.add("fields." + key + "=" + LaFunctions.u(s))));
            });
            form.as.entrySet().stream().filter(e -> e.getValue() != null).forEach(e -> {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 14K bytes
    - Viewed (0)
  2. cmd/testdata/undeleteable-object.tgz

    Kƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ‰ Z•`=A#µß ñN`áÚ¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘ ªPartASizes‘ ¤Size ¥MTimeÓ É ¸í80§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¬content-type¸application/octet-stream¤etagÙ 08ba8b8411960c5bc1e2¡v ΰ\ Ë ¤nullÄ%O‹óãB !EÆÐ ÃóÑÑä´.5t Ã*uºÅ{ _dùrd=EC multisitea/data/disterasure/xl3/.minio.sys/config/iam/format.json/xl.meta XL2 Æ o Ä$•Ä Ó ÉŸþ¦ ÆHÄ ¼… Å Cƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ÷ ·_ñ7MùtyÑ ÿ? ¦EcAlgo £EcM £EcN §EcBSizeÒ...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 26 00:31:12 UTC 2024
    - 8.7M bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb1/smb1/SmbAuthExceptionTest.java

    package jcifs.smb1.smb1;
    
    import static org.junit.jupiter.api.Assertions.assertEquals;
    
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    import org.junit.jupiter.params.provider.Arguments;
    import org.junit.jupiter.params.provider.MethodSource;
    
    /**
     * Tests for {@link SmbAuthException}.
     *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/entity/SearchRequestParams.java

                return true;
            }
            return stream(values).get(stream -> stream.allMatch(StringUtil::isBlank));
        }
    
        /**
         * Simplifies the array.
         *
         * @param values The array.
         * @return The simplified array.
         */
        protected static String[] simplifyArray(final String[] values) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

         */
        protected boolean isTargetUser(final String username) {
            if (targetUsers == null) {
                return true;
            }
            return stream(targetUsers).get(stream -> stream.anyMatch(s -> s.equals(username)));
        }
    
        /**
         * Executes an external command with the given parameters.
         * @param commands The command array to execute.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/service/RoleService.java

                op.setRefreshPolicy(Constants.TRUE);
            });
    
            userBhv.selectCursor(cb -> cb.query().setRoles_Equal(role.getId()), entity -> {
                entity.setRoles(
                        stream(entity.getRoles()).get(stream -> stream.filter(s -> !s.equals(role.getId())).toArray(n -> new String[n])));
                userBhv.insertOrUpdate(entity);
            });
        }
    
        /**
         * Sets up the list condition for the role query.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/Serialization.java

          Map<K, V> map, ObjectOutputStream stream) throws IOException {
        stream.writeInt(map.size());
        for (Map.Entry<K, V> entry : map.entrySet()) {
          stream.writeObject(entry.getKey());
          stream.writeObject(entry.getValue());
        }
      }
    
      /**
       * Populates a map by reading an input stream, as part of deserialization. See {@link #writeMap}
       * for the data format.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb1/util/Base64Test.java

    package jcifs.smb1.util;
    
    import static org.junit.jupiter.api.Assertions.assertArrayEquals;
    import static org.junit.jupiter.api.Assertions.assertEquals;
    import static org.junit.jupiter.api.Assertions.assertThrows;
    
    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
    - 3K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb1/util/MimeMapTest.java

            void testUnknownExtension() throws IOException {
                assertEquals("application/octet-stream", mimeMap.getMimeType("unknownext"));
                assertEquals("application/octet-stream", mimeMap.getMimeType("notfound"));
                assertEquals("application/octet-stream", mimeMap.getMimeType("doesnotexist"));
            }
    
            @Test
            @DisplayName("Should handle case insensitive extensions")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/util/JobProcess.java

     * This class provides access to the underlying process and manages
     * the input stream thread for capturing process output.
     */
    public class JobProcess {
        /**
         * The underlying system process.
         */
        protected Process process;
    
        /**
         * The thread that handles reading from the process input stream.
         */
        protected InputStreamThread inputStreamThread;
    
        /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.4K bytes
    - Viewed (0)
Back to top