Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 779 for asStream (0.11 sec)

  1. src/main/java/org/codelibs/fess/job/PingSearchEngineJob.java

                            postcard.addReplyTo(fessConfig.getMailReturnPath());
                            if (toAddresses.length > 0) {
                                stream(toAddresses).of(stream -> stream.map(String::trim).forEach(address -> {
                                    postcard.addTo(address);
                                }));
                            } else {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. api/maven-api-core/src/main/java/org/apache/maven/api/Node.java

         */
        @Nonnull
        String asString();
    
        /**
         * Obtain a Stream containing this node and all its descendant.
         *
         * @return a stream containing this node and its descendant
         */
        @Nonnull
        default Stream<Node> stream() {
            return Stream.concat(Stream.of(this), getChildren().stream().flatMap(Node::stream));
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Jun 11 07:23:04 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/HashMultimap.java

      @J2ktIncompatible
      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        Serialization.writeMultimap(this, stream);
      }
    
      @GwtIncompatible // java.io.ObjectInputStream
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        expectedValuesPerKey = DEFAULT_VALUES_PER_KEY;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 10:02:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

     */
    package org.codelibs.fess.app.service;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.io.IOException;
    import java.io.Reader;
    import java.io.Writer;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/TreeMultimap.java

       */
      @GwtIncompatible // java.io.ObjectOutputStream
      @J2ktIncompatible
      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeObject(keyComparator());
        stream.writeObject(valueComparator());
        Serialization.writeMultimap(this, stream);
      }
    
      @GwtIncompatible // java.io.ObjectInputStream
      @J2ktIncompatible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Mar 09 00:21:17 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. 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;
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:30:48 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/service/GroupService.java

                op.setRefreshPolicy(Constants.TRUE);
            });
    
            userBhv.selectCursor(cb -> cb.query().setGroups_Equal(group.getId()), entity -> {
                entity.setGroups(
                        stream(entity.getGroups()).get(stream -> stream.filter(s -> !s.equals(group.getId())).toArray(n -> new String[n])));
                userBhv.insertOrUpdate(entity);
            });
    
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. 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);
            });
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

         * weight from the default (16) to a new value.
         *
         * @param streamId stream which has a priority change.
         * @param streamDependency the stream ID this stream is dependent on.
         * @param weight relative proportion of priority in `[1..256]`.
         * @param exclusive inserts this stream ID as the sole child of `streamDependency`.
         */
        fun priority(
          streamId: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/InvokerRequest.java

        @Nonnull
        Optional<Path> rootDirectory();
    
        /**
         * Returns the input stream for the Maven execution, if running in embedded mode.
         *
         * @return an {@link Optional} containing the input stream, or empty if not applicable
         */
        @Nonnull
        Optional<InputStream> in();
    
        /**
         * Returns the output stream for the Maven execution, if running in embedded mode.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Oct 17 08:06:47 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top