Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 512 for reading_ (0.11 sec)

  1. okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt

       * TODO description.
       *
       * No further calls to this listener will be made.
       */
      open fun onClosed(eventSource: EventSource) {
      }
    
      /**
       * Invoked when an event source has been closed due to an error reading from or writing to the
       * network. Incoming events may have been lost. No further calls to this listener will be made.
       */
      open fun onFailure(
        eventSource: EventSource,
        t: Throwable?,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  2. architecture/networking/pilot.md

    ```mermaid
    graph TD
        subgraph ConfigStore
            xcs(XDS Client)
            ccs(CRD Client)
            fcs(Filesystem Client)
            acs(Aggregate)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Feb 07 17:53:24 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  3. src/archive/zip/example_test.go

    			log.Fatal(err)
    		}
    	}
    
    	// Make sure to check the error on Close.
    	err := w.Close()
    	if err != nil {
    		log.Fatal(err)
    	}
    }
    
    func ExampleReader() {
    	// Open a zip archive for reading.
    	r, err := zip.OpenReader("testdata/readme.zip")
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer r.Close()
    
    	// Iterate through the files in the archive,
    	// printing some of their contents.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jan 27 00:22:03 UTC 2016
    - 2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/LinkedHashMultimap.java

        valueSetCapacity = DEFAULT_VALUE_SET_CAPACITY;
        int distinctKeys = stream.readInt();
        Map<K, Collection<V>> map = Platform.newLinkedHashMapWithExpectedSize(12);
        for (int i = 0; i < distinctKeys; i++) {
          @SuppressWarnings("unchecked")
          K key = (K) stream.readObject();
          map.put(key, createCollection(key));
        }
        int entries = stream.readInt();
        for (int i = 0; i < entries; i++) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  5. api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/XmlReaderException.java

     */
    package org.apache.maven.api.services.xml;
    
    import org.apache.maven.api.annotations.Experimental;
    import org.apache.maven.api.services.MavenException;
    
    /**
     * An exception thrown during the reading of an xml file.
     *
     * @since 4.0.0
     */
    @Experimental
    public class XmlReaderException extends MavenException {
    
        private final Location location;
    
        /**
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Mon Mar 25 10:50:01 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/Closeables.java

       *
       * <p>While it's not safe in the general case to ignore exceptions that are thrown when closing an
       * I/O resource, it should generally be safe in the case of a resource that's being used only for
       * reading, such as an {@code InputStream}. Unlike with writable resources, there's no chance that
       * a failure that occurs when closing the stream indicates a meaningful problem such as a failure
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

      var complete = (upstream == null)
    
      /** The most recently read bytes from [upstream]. This is a suffix of [file]. Guarded by this. */
      val buffer = Buffer()
    
      /**
       * Reference count of the number of active sources reading this stream. When decremented to 0
       * resources are released and all following calls to [.newSource] return null. Guarded by this.
       */
      var sourceCount = 0
    
      val isClosed: Boolean
        get() = file == null
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/dependencies/global-dependencies.md

    ## Dependencies for groups of *path operations*
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  9. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

    import okio.ByteString
    import okio.ByteString.Companion.decodeHex
    import okio.FileSystem
    import okio.Path
    import okio.Path.Companion.toOkioPath
    import okio.buffer
    import okio.source
    
    /**
     * Utilities for reading HPACK tests.
     */
    object HpackJsonUtil {
      @Suppress("unused")
      private val MOSHI =
        Moshi.Builder()
          .add(
            object : Any() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. tensorflow/c/eager/c_api_experimental_reader.h

    // test();
    // int64_t value = TFE_MonitoringReadCounter1(reader, "label-value");
    
    // Opaque handle to a reader.
    typedef struct TFE_MonitoringCounterReader TFE_MonitoringCounterReader;
    
    // Returns a handle to be used for reading values from streamz counter. The
    // counter can have been created with any number of labels.
    TF_CAPI_EXPORT extern TFE_MonitoringCounterReader*
    TFE_MonitoringNewCounterReader(const char* name);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 20 03:14:47 UTC 2023
    - 2.3K bytes
    - Viewed (0)
Back to top