- Sort Score
- Num 10 results
- Language All
Results 821 - 830 of 1,233 for jstream (0.05 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)