- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 857 for jstream (0.08 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 {
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 4.4K bytes - Click Count (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 {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 15:50:50 GMT 2025 - 5.2K bytes - Click Count (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;
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 8.4K bytes - Click Count (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;Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 6.8K bytes - Click Count (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) {Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 2.5K bytes - Click Count (0) -
guava/src/com/google/common/collect/EnumMultiset.java
return Multisets.iteratorImpl(this); } @GwtIncompatible // java.io.ObjectOutputStream private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(type); Serialization.writeMultiset(this, stream); } /** * @serialData the {@code Class<E>} for the enum type, the number of distinct elements, the first
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 9.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/ldap/LdapUser.java
return stream(getPermissions()).get(stream -> stream.filter(s -> s.startsWith(fessConfig.getRoleSearchRolePrefix())) .map(s -> s.substring(1)) .toArray(n -> new String[n])); } @Override public String[] getGroupNames() { final FessConfig fessConfig = ComponentUtil.getFessConfig();
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 4.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/converter/KatakanaConverter.java
try (TokenStream stream = createTokenStream(rd)) { if (stream == null) { throw new IOException("Invalid tokenizer."); } stream.reset(); int offset = 0; while (stream.incrementToken()) { final CharTermAttribute att = stream.getAttribute(CharTermAttribute.class);
Created: Sat Dec 20 13:04:59 GMT 2025 - Last Modified: Fri Jul 04 14:00:23 GMT 2025 - 6.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
final Stream<QueryLog> stream = Stream.of(queryLogs); if (parallel) { stream.parallel(); } final SuggestItem[] array = stream.flatMap(queryLog -> contentsParser .parseQueryLog(queryLog, supportedFields, tagFieldNames, roleFieldName, readingConverter, normalizer) .stream()).toArray(SuggestItem[]::new);
Created: Sat Dec 20 13:04:59 GMT 2025 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 34.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 86.3K bytes - Click Count (0)