- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,102 for Stream (0.4 sec)
-
android/guava/src/com/google/common/io/LittleEndianDataInputStream.java
@J2ktIncompatible @GwtIncompatible public final class LittleEndianDataInputStream extends FilterInputStream implements DataInput { /** * Creates a {@code LittleEndianDataInputStream} that wraps the given stream. * * @param in the stream to delegate to */ public LittleEndianDataInputStream(InputStream in) { super(Preconditions.checkNotNull(in)); } /** This method will throw an {@link UnsupportedOperationException}. */Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Feb 12 03:49:18 UTC 2025 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/PhraseQueryCommand.java
context.addFieldLog(field, text); stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t))); return buildDefaultQueryBuilder(fessConfig, context, (f, b) -> buildMatchPhraseQuery(f, text).boost(b * boost)); } if (isSearchField(field)) { context.addFieldLog(field, text); stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t)));
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 4.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProtocolHelper.java
webProtocols = split(fessConfig.getCrawlerWebProtocols(), ",") .get(stream -> stream.filter(StringUtil::isNotBlank).map(s -> s.trim() + ":").toArray(n -> new String[n])); fileProtocols = split(fessConfig.getCrawlerFileProtocols(), ",") .get(stream -> stream.filter(StringUtil::isNotBlank).map(s -> s.trim() + ":").toArray(n -> new String[n]));
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Dec 12 13:58:40 UTC 2025 - 12.4K bytes - Viewed (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: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 4.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multimaps.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(factory); stream.writeObject(backingMap()); } @GwtIncompatible @J2ktIncompatible @SuppressWarnings("unchecked") // reading data stored by writeObject private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 18:35:44 UTC 2025 - 86.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/EnumHashBiMap.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(keyTypeOrObjectUnderJ2cl); Serialization.writeMap(this, stream); } @SuppressWarnings("unchecked") // reading field populated by writeObject @GwtIncompatible // java.io.ObjectInputStream private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 15:50:50 UTC 2025 - 5.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java
} } /** * Writes OpenSearch CAT API responses to the ZIP output stream. * * @param zos the ZIP output stream to write to * @param id the diagnostic ID for organizing files in the ZIP */ protected void writeFesenCat(final ZipOutputStream zos, final String id) { Arrays.stream(CAT_NAMES).forEach(name -> {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 18.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/relatedquery/ApiAdminRelatedqueryAction.java
*/ package org.codelibs.fess.app.web.api.admin.relatedquery; import static org.codelibs.core.stream.StreamUtil.stream; import static org.codelibs.fess.app.web.admin.relatedquery.AdminRelatedqueryAction.getRelatedQuery; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 8.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/ArrayListMultimap.java
@GwtIncompatible @J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); Serialization.writeMultimap(this, stream); } @GwtIncompatible @J2ktIncompatible private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject(); expectedValuesPerKey = DEFAULT_VALUES_PER_KEY;Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 05 23:15:58 UTC 2025 - 6.8K bytes - Viewed (0) -
compat/maven-repository-metadata/src/main/java/org/apache/maven/artifact/repository/metadata/io/xpp3/MetadataXpp3Writer.java
} } /** * Method write. * * @param stream a stream object * @param metadata a Metadata object * @throws java.io.IOException java.io.IOException if any */ public void write(OutputStream stream, Metadata metadata) throws java.io.IOException { try { delegate.write(stream, metadata.getDelegate()); } catch (XMLStreamException e) {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.5K bytes - Viewed (0)