Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 1,041 for jstream (0.05 seconds)

  1. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/UpgradePropertiesRuleSetup.java

    import java.util.AbstractMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.function.Function;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import static gradlebuild.binarycompatibility.upgrades.UpgradedProperties.CURRENT_ACCESSORS_OF_UPGRADED_PROPERTIES;
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Mon Aug 19 15:30:48 GMT 2024
    - 4.5K bytes
    - Click Count (0)
  2. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/CompatibilityFixStrategy.java

            // Collect all build elements to process
            Stream<BuildContainer> buildContainers = Stream.concat(
                    // Root level build
                    Stream.of(new BuildContainer(root.child(BUILD).orElse(null), BUILD))
                            .filter(container -> container.element != null),
                    // Profile builds
                    root.child(PROFILES).stream()
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 22.2K bytes
    - Click Count (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/HtmlExtractor.java

            try {
                final ExtractData extractData = new ExtractData(
                        StreamUtil.stream(getStringsByXPath(document, contentXpath)).get(stream -> stream.collect(Collectors.joining(" "))));
                metadataXpathMap.entrySet().stream().forEach(e -> {
                    extractData.putValues(e.getKey(), getStringsByXPath(document, e.getValue()));
                });
                return extractData;
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Oct 04 08:47:19 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  4. 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.
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  5. 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) {
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Nov 23 12:19:14 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  6. 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) {
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/api/admin/dict/ApiAdminDictAction.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.api.admin.dict;
    
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.codelibs.fess.app.web.api.ApiResult;
    import org.codelibs.fess.app.web.api.admin.FessApiAdminAction;
    import org.codelibs.fess.dict.DictionaryFile;
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/ReactorReader.java

            }
        }
    
        /**
         * Retrieve a stream of the project's artifacts
         */
        private Stream<Artifact> getProjectArtifacts(MavenProject project) {
            Stream<org.apache.maven.artifact.Artifact> artifacts = Stream.concat(
                    Stream.concat(
                            // pom artifact
                            Stream.of(new ProjectArtifact(project)),
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Dec 15 11:20:38 GMT 2025
    - 24.4K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/core/io/ReaderUtil.java

        /**
         * Creates a {@link Reader} to read from a file with the specified encoding.
         *
         * @param is
         *            the input stream (must not be {@literal null})
         * @param encoding
         *            the encoding of the input stream (must not be {@literal null} or empty)
         * @return a {@link Reader} to read from the file
         */
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/primitives/ImmutableLongArray.java

        }
      }
    
      /**
       * Returns a stream over the values in this array, in order.
       *
       * @since 33.4.0 (but since 22.0 in the JRE flavor)
       */
      // If users use this when they shouldn't, we hope that NewApi will catch subsequent stream calls
      @IgnoreJRERequirement
      public LongStream stream() {
        return Arrays.stream(array, start, end);
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 14:49:24 GMT 2025
    - 22K bytes
    - Click Count (0)
Back to Top