Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 1,713 for Take (0.11 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                BrokenChannel bc = new BrokenChannel();
                bc.doBegin();
                isInterruptibleRegistered.countDown();
                new CountDownLatch(1).await(); // the interrupt will wake us up
                return null;
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
              @Override
              String toPendingString() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. internal/grid/connection_test.go

    		return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    			t.Logf("Got a %s request for: %v", r.Method, r.URL)
    			handler.ServeHTTP(w, r)
    		})
    	}
    	connReady := make(chan struct{})
    	// We fake a local and remote server.
    	localHost := hosts[0]
    	remoteHost := hosts[1]
    	local, err := NewManager(context.Background(), ManagerOptions{
    		Dialer: ConnectWS(dialer.DialContext,
    			dummyNewToken,
    			nil),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:44:00 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. CREDITS

        Licensable by such Contributor to use, reproduce, make available,
        modify, display, perform, distribute, and otherwise exploit its
        Contributions, either on an unmodified basis, with Modifications, or
        as part of a Larger Work; and
    
    (b) under Patent Claims of such Contributor to make, use, sell, offer
        for sale, have made, import, and otherwise transfer either its
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 1.6M bytes
    - Viewed (0)
  4. istioctl/pkg/cli/context.go

    }
    
    type NewFakeContextOption struct {
    	Namespace      string
    	IstioNamespace string
    	Results        map[string][]byte
    	// Objects are the objects to be applied to the fake client
    	Objects []runtime.Object
    	// Version is the version of the fake client
    	Version string
    }
    
    func NewFakeContext(opts *NewFakeContextOption) Context {
    	if opts == nil {
    		opts = &NewFakeContextOption{}
    	}
    	ns := opts.Namespace
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. docs/en/docs/tutorial/security/simple-oauth2.md

    But `OAuth2PasswordRequestForm` is just a class dependency that you could have written yourself, or you could have declared `Form` parameters directly.
    
    But as it's a common use case, it is provided by **FastAPI** directly, just to make it easier.
    
    ///
    
    ### Use the form data
    
    /// tip
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.13.md

    * Delay CSI client initialization to make reconstruction of CSI volume possible because clients may not be available on kubelet restart. ([#74652](https://github.com/kubernetes/kubernetes/pull/74652), [@cofyc](https://github.com/cofyc))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu May 05 13:44:43 UTC 2022
    - 273.1K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst()
    
        // Do blocking calls to plan a route for a new connection.
        val connect = planConnect()
    
        // Now that we have a set of IP addresses, make another attempt at getting a connection from
        // the pool. We have a better chance of matching thanks to connection coalescing.
        val pooled2 = planReusePooledConnection(connect, connect.routes)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        final AtomicInteger totalCalls = new AtomicInteger();
        Runnable intCounter =
            new Runnable() {
              @Override
              public void run() {
                totalCalls.incrementAndGet();
                // Make sure that no other tasks are scheduled to run while this is running.
                assertFalse(fakePool.hasNext());
              }
            };
    
        assertFalse(fakePool.hasNext());
        e.execute(intCounter);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/InterruptibleTask.java

      @Override
      public final void run() {
        /*
         * Set runner thread before checking isDone(). If we were to check isDone() first, the task
         * might be cancelled before we set the runner thread. That would make it impossible to
         * interrupt, yet it will still run, since interruptTask will leave the runner value null,
         * allowing the CAS below to succeed.
         */
        Thread currentThread = Thread.currentThread();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. docs/en/docs/tutorial/security/oauth2-jwt.md

    Many packages that simplify it a lot have to make many compromises with the data model, database, and available features. And some of these packages that simplify things too much actually have security flaws underneath.
    
    ---
    
    **FastAPI** doesn't make any compromise with any database, data model or tool.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 26 11:45:10 UTC 2024
    - 12.8K bytes
    - Viewed (0)
Back to top