- Sort Score
- Num 10 results
- Language All
Results 571 - 580 of 1,215 for stream (0.04 seconds)
-
guava/src/com/google/common/collect/ImmutableEnumMap.java
@Override @J2ktIncompatible // serialization Object writeReplace() { return new EnumSerializedForm<>(delegate); } @J2ktIncompatible // serialization private void readObject(ObjectInputStream stream) throws InvalidObjectException { throw new InvalidObjectException("Use EnumSerializedForm"); } /* * This class is used to serialize ImmutableEnumMap instances. */
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 16:16:42 GMT 2026 - 4.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java
}); }); } /** * Download the stemmer override dictionary file. * Streams the dictionary file as an octet-stream download. * * @param form The download form containing dictionary ID * @return Action response with file stream for download */ @Execute @Secured({ ROLE, ROLE + VIEW }) public ActionResponse download(final DownloadForm form) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 23.5K bytes - Click Count (0) -
android/guava/src/com/google/common/io/LineReader.java
* linefeed ({@code "\r\n"}). * * @return a {@code String} containing the contents of the line, not including any * line-termination characters, or {@code null} if the end of the stream has been reached. * @throws IOException if an I/O error occurs */ @CanIgnoreReturnValue // to skip a line public @Nullable String readLine() throws IOException { while (lines.peek() == null) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 3K bytes - Click Count (0) -
guava/src/com/google/common/collect/ImmutableAsList.java
} @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0; } @GwtIncompatible @J2ktIncompatible private void readObject(ObjectInputStream stream) throws InvalidObjectException { throw new InvalidObjectException("Use SerializedForm"); } @GwtIncompatible @J2ktIncompatible @Override Object writeReplace() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 2.5K bytes - Click Count (0) -
guava/src/com/google/common/collect/LinkedHashMultimap.java
@J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeInt(keySet().size()); for (K key : keySet()) { stream.writeObject(key); } stream.writeInt(size()); for (Entry<K, V> entry : entries()) { stream.writeObject(entry.getKey()); stream.writeObject(entry.getValue()); } } @GwtIncompatibleCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 26 20:08:09 GMT 2025 - 20K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/opensearch/config/exentity/DataConfig.java
import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.function.Supplier; import java.util.regex.Pattern; import java.util.stream.Collectors; import org.apache.http.auth.UsernamePasswordCredentials; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Jan 10 01:38:30 GMT 2026 - 17.7K bytes - Click Count (0) -
internal/grid/connection_test.go
local.debugMsg(debugKillInbound) <-gotResp // Must reconnect errFatal(remoteConn.WaitForConnect(t.Context())) stream, err := remoteConn.NewStream(t.Context(), handlerTest2, []byte(testPayload)) errFatal(err) go func() { for resp := range stream.responses { t.Log("Resp:", resp, err) } gotResp <- struct{}{} }() <-gotCall remote.debugMsg(debugKillOutbound)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 5.9K bytes - Click Count (0) -
internal/bucket/lifecycle/tag.go
) // UnmarshalXML - decodes XML data. func (tag *Tag) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) { var keyAlreadyParsed, valueAlreadyParsed bool for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { var s string
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 2.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/TreeMultiset.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(elementSet().comparator()); Serialization.writeMultiset(this, stream); } @J2ktIncompatible @GwtIncompatible private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject(); @SuppressWarnings("unchecked")
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 34K bytes - Click Count (0) -
cmd/metacache-server-pool.go
o.SetFilter() if o.Transient { o.Create = false } // We have 2 cases: // 1) Cold listing, just list. // 2) Returning, but with no id. Start async listing. // 3) Returning, with ID, stream from list. // // If we don't have a list id we must ask the server if it has a cache or create a new. if o.ID != "" && !o.Transient { // Create or ping with handout...
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12.9K bytes - Click Count (0)