Search Options

Results per page
Sort
Preferred Languages
Advance

Results 471 - 480 of 1,021 for streams (0.12 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/plugin/PluginResolutionException.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.plugin;
    
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.maven.model.Plugin;
    
    /**
     * Exception occurring trying to resolve a plugin.
     *
     */
    public class PluginResolutionException extends Exception {
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

          inFinished: Boolean,
          streamId: Int,
          source: BufferedSource,
          length: Int,
        ) {
          check(type == -1)
          this.type = Http2.TYPE_DATA
          this.inFinished = inFinished
          this.streamId = streamId
          this.data = source.readByteString(length.toLong()).toByteArray()
        }
    
        override fun rstStream(
          streamId: Int,
          errorCode: ErrorCode,
        ) {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/main/java/org/codelibs/fess/app/web/api/admin/dict/stemmeroverride/ApiAdminDictStemmeroverrideAction.java

    import static org.codelibs.fess.app.web.admin.dict.stemmeroverride.AdminDictStemmeroverrideAction.createStemmerOverrideItem;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.StemmerOverridePager;
    import org.codelibs.fess.app.service.StemmerOverrideService;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top