- Sort Score
- Result 10 results
- Languages All
Results 501 - 510 of 858 for callEnd (0.56 sec)
-
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) -
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} objectsRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 25 15:01:23 UTC 2025 - 20.6K bytes - Viewed (0) -
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} objectsRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 25 15:01:23 UTC 2025 - 20.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)