Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 365 for cancels (0.06 sec)

  1. guava/src/com/google/common/util/concurrent/FluentFuture.java

          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
        @Override
        public final boolean cancel(boolean mayInterruptIfRunning) {
          return super.cancel(mayInterruptIfRunning);
        }
      }
    
      FluentFuture() {}
    
      /**
       * Converts the given {@code ListenableFuture} to an equivalent {@code FluentFuture}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

    import javax.inject.Singleton;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.RandomAccessFile;
    import java.nio.channels.Channels;
    import java.nio.channels.FileChannel;
    import java.nio.channels.FileLock;
    import java.util.Date;
    import java.util.Properties;
    
    import org.apache.maven.artifact.Artifact;
    import org.apache.maven.artifact.repository.ArtifactRepository;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    		}
    	}
    
    	// Check if target is a MinIO server and alive
    	hcCtx, cancel := context.WithTimeout(ctx, 3*time.Second)
    	scheme := "http"
    	if tgt.Secure {
    		scheme = "https"
    	}
    	result := <-sys.hcClient.Alive(hcCtx, madmin.AliveOpts{}, madmin.ServerProperties{
    		Endpoint: tgt.Endpoint,
    		Scheme:   scheme,
    	})
    
    	cancel()
    	if result.Error != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          // code should be unreachable with correctly implemented Futures.
          // Cancel this future and return.
          // At this point, inputFuture is cancelled and outputFuture doesn't exist, so the value of
          // mayInterruptIfRunning is irrelevant.
          cancel(false);
          return;
        } catch (ExecutionException e) {
          // Set the cause of the exception as this future's exception.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. fastapi/security/http.py

            auto_error: Annotated[
                bool,
                Doc(
                    """
                    By default, if the HTTP Basic authentication is not provided (a
                    header), `HTTPBasic` will automatically cancel the request and send the
                    client an error.
    
                    If `auto_error` is set to `False`, when the HTTP Basic authentication
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Sep 19 09:47:28 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  6. src/main/java/jcifs/util/transport/Request.java

         */
        int getCreditCost ();
    
    
        /**
         * @param credits
         */
        void setRequestCredits ( int credits );
    
    
        /**
         * @return whether this is a cancel request
         */
        boolean isCancel ();
    
    
        /**
         * @return chained request
         */
        Request getNext ();
    
    
        /**
         * @return the response for this request
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/MoreExecutors.java

          }
    
          @Override
          public boolean cancel(boolean mayInterruptIfRunning) {
            boolean cancelled = super.cancel(mayInterruptIfRunning);
            if (cancelled) {
              // Unless it is cancelled, the delegate may continue being scheduled
              scheduledDelegate.cancel(mayInterruptIfRunning);
    
              // TODO(user): Cancel "this" if "scheduledDelegate" is cancelled.
            }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  8. fastapi/security/open_id_connect_url.py

                bool,
                Doc(
                    """
                    By default, if no HTTP Authorization header is provided, required for
                    OpenID Connect authentication, it will automatically cancel the request
                    and send the client an error.
    
                    If `auto_error` is set to `False`, when the HTTP Authorization header
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  9. cmd/test-utils_test.go

    		setObjectLayer(newObjectLayerFn())
    		cancel()
    		removeRoots(fsDirs)
    	}
    }
    
    // ExecObjectLayerTestWithDirs - executes object layer tests.
    // Creates single node and Erasure ObjectLayer instance and runs test for both the layers.
    func ExecObjectLayerTestWithDirs(t TestErrHandler, objTest objTestTypeWithDirs) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	if localMetacacheMgr != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/ErrorCode.kt

    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.2K bytes
    - Viewed (0)
Back to top