Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 1,030 for stream (1.61 sec)

  1. android/guava-tests/test/com/google/common/collect/LockHeldAssertingSet.java

       *   holdsLock assertions.
       *
       * - For stream() and spliterator(), we have to forward to the delegate ourselves because
       *   ForwardingSet does not forward `default` methods, as discussed in its Javadoc.
       */
    
      // Currently, we don't include stream() and spliterator() for our classes in the Android flavor.
    
      @Override
      public boolean remove(@Nullable Object o) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  2. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java

         */
        Model read(Reader input, Map<String, ?> options) throws IOException, ModelParseException;
    
        /**
         * Reads the model from the specified byte stream. The stream will be automatically closed before the method
         * returns.
         *
         * @param input The stream to deserialize the model from, must not be {@code null}.
         * @param options The options to use for deserialization, may be {@code null} to use the default values.
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Feb 25 08:27:34 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java

            }
        }
    
        /**
         * Reloads the character mapping items from the provided input stream.
         * Parses mapping rules in the format: input1,input2,... => output
         *
         * @param updater the mapping updater to use for writing changes, or null for read-only reload
         * @param in the input stream to read the mapping data from
         */
        protected void reload(final MappingUpdater updater, final InputStream in) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 20 05:56:45 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/thumbnail/ThumbnailAction.java

                }
                // 404
                throw responseManager.new404("Thumbnail for " + form.docId + " is under generating.");
            }
    
            return asStream(form.docId).contentType(getImageMimeType(thumbnailFile)).stream(out -> {
                try (BufferedInputStream in = new BufferedInputStream(new FileInputStream(thumbnailFile))) {
                    out.write(in);
                }
            });
        }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/QueryHelper.java

         */
        public void addDefaultSort(final String fieldName, final String order) {
            final List<SortBuilder<?>> list = new ArrayList<>();
            if (defaultSortBuilders != null) {
                stream(defaultSortBuilders).of(stream -> stream.forEach(builder -> list.add(builder)));
            }
            list.add(createFieldSortBuilder(fieldName, SortOrder.DESC.toString().equalsIgnoreCase(order) ? SortOrder.DESC : SortOrder.ASC));
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 19.9K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/api/WebApiResponse.java

    /**
     * Wrapper for HTTP servlet responses in web API context.
     * This class extends HttpServletResponseWrapper to provide custom response handling
     * for web API responses, including dummy output stream management.
     */
    public class WebApiResponse extends HttpServletResponseWrapper {
    
        /**
         * Constructs a WebApiResponse with the specified response.
         *
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  7. 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: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 20 05:56:45 UTC 2025
    - 36.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/opensearch/log/exentity/SearchLog.java

            }
            final Map<String, List<String>> searchFieldMap = searchFieldLogList.stream()
                    .collect(Collectors.groupingBy(Pair::getFirst, Collectors.mapping(Pair::getSecond, Collectors.toList())));
            sourceMap.put("searchField", searchFieldMap);
            final Map<String, List<String>> headerMap = headerList.stream()
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/dict/protwords/ProtwordsFile.java

            }
        }
    
        /**
         * Reloads the dictionary file with the specified updater and input stream.
         * @param updater the updater to use for processing items
         * @param in the input stream containing the file content
         */
        protected void reload(final ProtwordsUpdater updater, final InputStream in) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 07:09:00 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/util/transport/Transport.java

            // Default constructor
        }
    
        static int id = 0;
        static LogStream log = LogStream.getInstance();
    
        /**
         * Reads exactly len bytes from the input stream into the buffer.
         *
         * @param in the input stream to read from
         * @param b the buffer to read into
         * @param off the offset in the buffer to start writing
         * @param len the number of bytes to read
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11.3K bytes
    - Viewed (0)
Back to top