Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 571 - 580 of 1,215 for stream (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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());
        }
      }
    
      @GwtIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:08:09 GMT 2025
    - 20K bytes
    - Click Count (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top