Search Options

Results per page
Sort
Preferred Languages
Advance

Results 501 - 510 of 858 for callEnd (0.56 sec)

  1. cmd/warm-backend-gcs.go

    	// Refer to https://cloud.google.com/storage/docs/transcoding#decompressive_transcoding
    	// Need to set `Accept-Encoding` header to `gzip` when issuing a GetObject call, to be able
    	// to download the object in compressed state.
    	// Calling ReadCompressed with true accomplishes that.
    	object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key)).ReadCompressed(true)
    
    	r, err = object.NewRangeReader(ctx, opts.startOffset, opts.length)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/primitives/Booleans.java

       * values.
       *
       * <p>Elements are copied from the argument collection as if by {@code collection.toArray()}.
       * Calling this method is as thread-safe as calling that method.
       *
       * <p><b>Note:</b> consider representing the collection as a {@link java.util.BitSet} instead.
       *
       * @param collection a collection of {@code Boolean} objects
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 25 15:01:23 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/primitives/Booleans.java

       * values.
       *
       * <p>Elements are copied from the argument collection as if by {@code collection.toArray()}.
       * Calling this method is as thread-safe as calling that method.
       *
       * <p><b>Note:</b> consider representing the collection as a {@link java.util.BitSet} instead.
       *
       * @param collection a collection of {@code Boolean} objects
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 25 15:01:23 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

          if (!completedNormally) {
            startAnotherThread()
          }
        }
      }
    
      /**
       * Returns an immediately-executable task for the calling thread to execute, sleeping as necessary
       * until one is ready. If there are no ready queues, or if other threads have everything under
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

     *   <li>a {@linkplain ThreadFactory#newThread backing thread factory}
     * </ul>
     *
     * <p>If no backing thread factory is provided, a default backing thread factory is used as if by
     * calling {@code setThreadFactory(}{@link Executors#defaultThreadFactory()}{@code )}.
     *
     * <p><b>Java 21+ users:</b> consider using the {@code Thread.Builder} interface instead. E.g.,
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:35:26 UTC 2025
    - 9K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java

      }
    
      @CollectionFeature.Require(absent = SUPPORTS_REMOVE)
      public void testSetCount_negative_removeUnsupported() {
        try {
          setCountNoCheckReturnValue(e3(), -1);
          fail(
              "calling setCount() with a negative count should throw "
                  + "IllegalArgumentException or UnsupportedOperationException");
        } catch (IllegalArgumentException | UnsupportedOperationException expected) {
        }
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 13K bytes
    - Viewed (0)
  7. docs/features/calls.md

    Calls are executed in one of two ways:
    
     * **Synchronous:** your thread blocks until the response is readable.
     * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java

        @Override
        public int read(final byte[] b) throws IOException {
            return inputStream.read(b);
        }
    
        /**
         * Repositions this stream to the position at the time the mark method was last called.
         *
         * @throws IOException if this stream has not been marked or if the mark has been invalidated
         */
        @Override
        public synchronized void reset() throws IOException {
            inputStream.reset();
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java

                  // we reached EOF
                  return new String(buffer, 0, bufIndex);
                }
                // otherwise we got the size wrong.  This can happen if the size changes between when
                // we called sizeIfKnown and when we started reading the file (or I guess if
                // maxCharsPerByte is wrong)
                // Fallback to an incremental approach
                StringBuilder builder = new StringBuilder(bufIndex + 32);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  10. docs/bucket/retention/README.md

      - New objects inherit the retention settings of the bucket object lock configuration automatically
      - Retention headers can be optionally set while uploading objects
      - Once objects are uploaded PutObjectRetention API can be called to change retention settings
    - *MINIO_NTP_SERVER* environment variable can be set to remote NTP server endpoint if system time is not desired for setting retention dates.
    
    ## Explore Further
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 4K bytes
    - Viewed (0)
Back to top