Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 821 - 830 of 1,233 for jstream (0.05 seconds)

  1. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/rest/compat/RestCompatTestTransformTask.java

            return skippedTestByFilePatternTransformations.keySet().stream()
                .map(key -> String.join(",", key.getIncludes()) + skippedTestByFilePatternTransformations.get(key))
                .collect(Collectors.joining());
        }
    
        @Input
        public String getSkippedTestByTestNameTransformations() {
    
            return skippedTestByTestNameTransformations.keySet().stream()
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Sep 30 16:30:48 GMT 2021
    - 22.3K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/Synchronized.java

          synchronized (mutex) {
            return delegate().spliterator();
          }
        }
    
        @Override
        public Stream<E> stream() {
          synchronized (mutex) {
            return delegate().stream();
          }
        }
    
        @Override
        public Stream<E> parallelStream() {
          synchronized (mutex) {
            return delegate().parallelStream();
          }
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Aug 08 15:11:10 GMT 2025
    - 56.9K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/helper/SystemHelperTest.java

    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.codelibs.core.io.FileUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.misc.Pair;
    import org.codelibs.core.misc.Tuple3;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 44.4K bytes
    - Click Count (0)
  4. compat/maven-model/src/test/java/org/apache/maven/model/v4/ModelXmlTest.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.model.v4;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.IOException;
    import java.io.StringReader;
    import java.io.StringWriter;
    import java.util.LinkedHashMap;
    import java.util.Map;
    
    import org.apache.maven.api.model.Model;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 4K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/suggest/entity/ElevateWord.java

         *
         * @return a SuggestItem representing this ElevateWord
         */
        public SuggestItem toSuggestItem() {
            final String[][] readingArray =
                    this.getReadings().stream().map(reading -> new String[] { reading }).toArray(count -> new String[count][]);
            return new SuggestItem(new String[] { this.getElevateWord() }, readingArray, fields.toArray(new String[fields.size()]), 1, 0,
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Fri Jul 04 14:00:23 GMT 2025
    - 4K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

            }
    
            if (logger.isDebugEnabled()) {
                try {
                    ManagementFactory.getRuntimeMXBean().getInputArguments().stream().forEach(s -> logger.debug("Parameter: {}", s));
                    System.getProperties()
                            .entrySet()
                            .stream()
                            .forEach(e -> logger.debug("Property: {}={}", e.getKey(),
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java

    import static org.codelibs.fess.app.web.admin.scheduler.AdminSchedulerAction.getScheduledJob;
    
    import java.util.List;
    import java.util.Map;
    import java.util.UUID;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.app.pager.SchedulerPager;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 10.7K bytes
    - Click Count (0)
  8. docs/fr/docs/advanced/custom-response.md

    Au lieu de renvoyer une `StreamingResponse` directement, vous devriez probablement suivre le style de [Diffuser des données](./stream-data.md), c'est beaucoup plus pratique et gère l'annulation en arrière-plan pour vous.
    
    Si vous diffusez des JSON Lines, suivez le didacticiel [Diffuser des JSON Lines](../tutorial/stream-json-lines.md).
    
    ///
    
    ### `FileResponse` { #fileresponse }
    
    Diffuse de façon asynchrone un fichier comme réponse.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 12.3K bytes
    - Click Count (0)
  9. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/LoggerUsageTask.java

        @SkipWhenEmpty
        public FileCollection getClassDirectories() {
            return getProject().getExtensions().getByType(JavaPluginExtension.class)
                .getSourceSets()
                .stream()
                // Don't pick up all source sets like the java9 ones as logger-check doesn't support the class format
                .filter(
                    sourceSet -> sourceSet.getName().equals(SourceSet.MAIN_SOURCE_SET_NAME)
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Jun 17 08:59:22 GMT 2021
    - 2.8K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/crawler/serializer/DataSerializer.java

         * <p>
         * Uses the thread-local Kryo instance to serialize the object along with
         * its class information. The serialized data is written to a byte array
         * output stream.
         * </p>
         *
         * @param obj the object to serialize
         * @return the serialized object as a byte array
         * @throws IORuntimeException if an I/O error occurs during serialization
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Jan 10 01:54:09 GMT 2026
    - 10.5K bytes
    - Click Count (3)
Back to Top