Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 488 for reading_ (0.08 sec)

  1. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

          "timeout",
          "Read timed out",
        )
        assertThat(webSocket.close(1000, null)).isFalse()
      }
    
      /**
       * There's no read timeout when reading the first byte of a new frame. But as soon as we start
       * reading a frame we enable the read timeout. In this test we have the server returning the first
       * byte of a frame but no more frames.
       */
      @Test
      fun readTimeoutAppliesWithinFrames() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  2. cmd/batch-expire_gen.go

    				if err != nil {
    					err = msgp.WrapError(err, "Purge")
    					return
    				}
    				switch msgp.UnsafeString(field) {
    				case "RetainVersions":
    					z.Purge.RetainVersions, err = dc.ReadInt()
    					if err != nil {
    						err = msgp.WrapError(err, "Purge", "RetainVersions")
    						return
    					}
    				default:
    					err = dc.Skip()
    					if err != nil {
    						err = msgp.WrapError(err, "Purge")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

     *   ... // Handle the failure.
     *   }
     * });
     * ```
     *
     * These examples will not work if you're consuming the response body on another thread. In such
     * cases the consuming thread must call [close] when it has finished reading the response
     * body.
     *
     * ### The response body can be consumed only once.
     *
     * This class may be used to stream very large responses. For example, it is possible to use this
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/Cut.java

           * use the `endpoint` field, compareTo() and endpoint(). Additionally, the main implementation
           * of Cut.compareTo checks for belowAll before reading accessing `endpoint` on another Cut
           * instance.
           */
          super("");
        }
    
        @Override
        Comparable<?> endpoint() {
          throw new IllegalStateException("range unbounded on this side");
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbFileInputStream.java

            this(new SmbFile(url, tc), 0, SmbConstants.O_RDONLY, SmbConstants.DEFAULT_SHARING, true);
        }
    
    
        /**
         * Creates an {@link java.io.InputStream} for reading bytes from a file on
         * an SMB server represented by the {@link jcifs.smb.SmbFile} parameter. See
         * {@link jcifs.smb.SmbFile} for a detailed description and examples of
         * the smb URL syntax.
         *
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 08:55:14 UTC 2020
    - 13.2K bytes
    - Viewed (0)
  6. cmd/streaming-signature-v4.go

    // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read.
    //
    // NewChunkedReader is not needed by normal applications. The http package
    // automatically decodes chunking when reading response bodies.
    func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) {
    	cred, seedSignature, region, seedDate, errCode := calculateSeedSignature(req, trailer)
    	if errCode != ErrNone {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  7. internal/logger/target/kafka/kafka.go

    }
    
    // Target - Kafka target.
    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  8. cmd/batch-job-common-types_gen.go

    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "Attempts":
    			z.Attempts, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Attempts")
    				return
    			}
    		case "Delay":
    			z.Delay, err = dc.ReadDuration()
    			if err != nil {
    				err = msgp.WrapError(err, "Delay")
    				return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 21.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/TreeMultimap.java

        stream.writeObject(valueComparator());
        Serialization.writeMultimap(this, stream);
      }
    
      @GwtIncompatible // java.io.ObjectInputStream
      @J2ktIncompatible
      @SuppressWarnings("unchecked") // reading data stored by writeObject
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Mar 09 00:21:17 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v1.go

    	Checksums  map[string]string `json:"crc,omitempty" msg:"crc,omitempty"`   // Content Checksums
    	Error      string            `json:"error,omitempty" msg:"err,omitempty"` // only set while reading part meta from drive.
    }
    
    // ChecksumInfo - carries checksums of individual scattered parts per disk.
    type ChecksumInfo struct {
    	PartNumber int
    	Algorithm  BitrotAlgorithm
    	Hash       []byte
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top