Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 1,153 for caller (0.12 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

       * trailers are available to read.
       *
       * It is not safe to call this concurrently with code that is processing the response body. If you
       * call this without consuming the complete response body, any remaining bytes in the response
       * body will be discarded before trailers are returned.
       *
       * If [Call.cancel] is called while this is blocking, this call will immediately throw.
       *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 28 14:39:28 GMT 2025
    - 18.1K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/Futures.java

       * the {@code Future} is already done. Second, if buggy code calls {@code getDone} on a {@code
       * Future} that is still pending, the program will throw instead of block. This can be important
       * for APIs like {@link #whenAllComplete whenAllComplete(...)}{@code .}{@link
       * FutureCombiner#call(Callable, Executor) call(...)}, where it is easy to use a new input from
       * the {@code call} implementation but forget to add it to the arguments of {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

       * be thread-safe.
       *
       * @since 13.0
       */
      public interface Policy {
    
        /**
         * Called when a potential deadlock is encountered. Implementations can throw the given {@code
         * exception} and/or execute other desired logic.
         *
         * <p>Note that the method will be called even upon an invocation of {@code tryLock()}. Although
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/CollectSpliterators.java

       * advantages to having the type are the ability to use its constructor reference below and the
       * parallelism with the primitive version. In short, it makes its caller ({@code flatMap})
       * simpler.
       *
       * @param <InElementT> the element type of the input spliterator
       * @param <OutElementT> the element type of the output spliterators
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is
       * called multiple times.
       *
       * <p>When this method is called {@link #state()} will return {@link State#STOPPING}, which is the
       * external state observable by the caller of {@link #stopAsync}.
       *
       * @since 27.0
       */
      @ForOverride
      protected void doCancelStart() {}
    
      @CanIgnoreReturnValue
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  6. cmd/object-api-interface.go

    	CreatedAt         time.Time // only for site replication
    	NoLock            bool      // does not lock the make bucket call if set to 'true'
    }
    
    // DeleteBucketOptions provides options for DeleteBucket calls.
    type DeleteBucketOptions struct {
    	NoLock     bool             // does not lock the delete bucket call if set to 'true'
    	NoRecreate bool             // do not recreate bucket on delete failures
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java

            private final RequestOptionCall<BulkRequestBuilder> call;
    
            private final RequestOptionCall<B> entityCall;
    
            public BulkList(final List<E> parent, final RequestOptionCall<BulkRequestBuilder> call, final RequestOptionCall<B> entityCall) {
                this.parent = parent;
                this.entityCall = entityCall;
                this.call = call;
            }
    
            public int size() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 27 07:01:25 GMT 2025
    - 26.4K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/collect/CollectSpliterators.java

       * advantages to having the type are the ability to use its constructor reference below and the
       * parallelism with the primitive version. In short, it makes its caller ({@code flatMap})
       * simpler.
       *
       * @param <InElementT> the element type of the input spliterator
       * @param <OutElementT> the element type of the output spliterators
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  9. internal/config/identity/openid/openid.go

    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(ConfigURL) != ""
    }
    
    // GetSettings - fetches OIDC settings for site-replication related validation.
    // NOTE that region must be populated by caller as this package does not know.
    func (r *Config) GetSettings() madmin.OpenIDSettings {
    	res := madmin.OpenIDSettings{}
    	if !r.Enabled {
    		return res
    	}
    	h := sha256.New()
    	hashedSecret := ""
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 17.3K bytes
    - Click Count (0)
  10. internal/logger/target/http/http.go

    // format of a log entry to the configured http endpoint.
    // An internal buffer of logs is maintained but when the
    // buffer is full, new logs are just ignored and an error
    // is returned to the caller.
    type Target struct {
    	totalMessages  atomic.Int64
    	failedMessages atomic.Int64
    	status         atomic.Int32
    
    	// Worker control
    	workers    atomic.Int64
    	maxWorkers int64
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
Back to Top