Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 373 for asStream (0.35 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/fileconfig/AdminFileconfigAction.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.admin.fileconfig;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 13:56:35 UTC 2025
    - 19.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/web/admin/searchlist/ListForm.java

        public String sdh;
    
        @Override
        public String getQuery() {
            return q;
        }
    
        @Override
        public String[] getExtraQueries() {
            return stream(ex_q).get(stream -> stream.filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]));
        }
    
        @Override
        public Map<String, String[]> getFields() {
            return fields;
        }
    
        @Override
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  3. 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: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/webconfig/AdminWebconfigAction.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.admin.webconfig;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 13:56:35 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/util/InputStreamThread.java

    import java.util.function.Consumer;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    
    /**
     * A thread that reads from an input stream line by line and maintains a buffer of recent lines.
     * This class provides functionality to read input stream data asynchronously,
     * optionally process each line with a callback function, and maintain a circular buffer
     * of recent lines for retrieval.
     */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/base/SearchForm.java

        public String[] getExtraQueries() {
            return stream(ex_q).get(stream -> stream.filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]));
        }
    
        @Override
        public Map<String, String[]> getFields() {
            return fields;
        }
    
        @Override
        public String[] getLanguages() {
            return stream(lang).get(stream -> stream.filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]));
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/auth/AuthenticationManager.java

            return chains().get(stream -> stream.allMatch(c -> c.changePassword(username, password)));
        }
    
        /**
         * Deletes a user from all authentication chains.
         * @param user The user to delete.
         */
        public void delete(final User user) {
            chains().of(stream -> stream.forEach(c -> c.delete(user)));
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java

     *
     * <p>All other methods delegate to the wrapped input stream.</p>
     *
     */
    public class IgnoreCloseInputStream extends InputStream {
    
        /** The wrapped input stream. */
        private InputStream inputStream;
    
        /**
         * Constructs a new IgnoreCloseInputStream that wraps the specified input stream.
         *
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/util/LogStream.java

         * The current logging level.
         */
        public static int level = 1;
    
        /**
         * Constructs a LogStream with the specified output stream.
         *
         * @param stream the output stream for logging
         */
        public LogStream(final PrintStream stream) {
            super(stream);
        }
    
        /**
         * Sets the logging level.
         *
         * @param level the logging level to set
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/api/admin/dataconfig/ApiAdminDataconfigAction.java

            body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s))
                    .filter(StringUtil::isNotBlank)
                    .distinct()
                    .collect(Collectors.joining("\n")));
            body.virtualHosts = stream(entity.getVirtualHosts())
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 8.5K bytes
    - Viewed (0)
Back to top