Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 619 for completer (0.09 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

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

       * computation is {@linkplain java.util.concurrent.Future#isDone() complete} or, if the
       * computation is already complete, immediately.
       *
       * <p>The callback is run on {@code executor}. There is no guaranteed ordering of execution of
       * callbacks, but any callback added through this method is guaranteed to be called once the
       * computation is complete.
       *
       * <p>Example:
       *
       * {@snippet :
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

        }
    
        return e
      }
    
      /**
       * Complete this call. This should be called once these properties are all false:
       * [requestBodyOpen], [responseBodyOpen], [socketSinkOpen], [socketSourceOpen], and
       * [expectMoreExchanges].
       *
       * This will release the connection if it is still held.
       *
       * It will also notify the listener that the call completed; either successfully or
       * unsuccessfully.
       *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  3. src/test/java/jcifs/smb/CriticalPerformanceTest.java

            double totalTimeMs = (end - start) / 1_000_000.0;
    
            System.out.printf("Overall Performance Test: completed in %.2f ms%n", totalTimeMs);
    
            // Should complete very quickly with all optimizations
            assertTrue(totalTimeMs < 100, "All operations should complete quickly with performance fixes");
    
            pool.close();
        }
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                  }
                }
              });
          executor.execute(
              new Runnable() {
                @Override
                public void run() {
                  future.cancel(true);
                  if (!future.isDone()) {
                    errorMessage.set("Cancel call exited before future was complete.");
                  }
                }
              });
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  5. cmd/erasure-server-pool-decom.go

    	type poolInfo struct {
    		position     int
    		completed    bool
    		decomStarted bool // started but not finished yet
    	}
    
    	rememberedPools := make(map[string]poolInfo)
    	for idx, pool := range p.Pools {
    		complete := false
    		decomStarted := false
    		if pool.Decommission != nil {
    			if pool.Decommission.Complete {
    				complete = true
    			}
    			decomStarted = true
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  6. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

      private TimeoutFuture(ListenableFuture<V> delegate) {
        this.delegateRef = Preconditions.checkNotNull(delegate);
      }
    
      /** A runnable that is called when the delegate or the timer completes. */
      private static final class Fire<V extends @Nullable Object> implements Runnable {
        @LazyInit @Nullable TimeoutFuture<V> timeoutFutureRef;
    
        Fire(TimeoutFuture<V> timeoutFuture) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

        // But they disappear when the edit completes.
        sink0.close()
        editor.commit()
        assertThat(readFileOrNull(getCleanFile("k1", 0))).isNull()
        assertThat(readFileOrNull(getDirtyFile("k1", 0))).isNull()
      }
    
      @Test
      fun `close with completed zombie write`() {
        val afterRemoveCleanFileContents = if (windows) "a" else null
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 59.4K bytes
    - Click Count (0)
  8. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    	response, err = x.ClientConversation.Step(challenge)
    	return response, err
    }
    
    // Done returns true if the conversation is completed or has errored.
    func (x *XDGSCRAMClient) Done() bool {
    	return x.ClientConversation.Done()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                  }
                }
              });
          executor.execute(
              new Runnable() {
                @Override
                public void run() {
                  future.cancel(true);
                  if (!future.isDone()) {
                    errorMessage.set("Cancel call exited before future was complete.");
                  }
                }
              });
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  10. docs/en/docs/tutorial/security/simple-oauth2.md

    # Simple OAuth2 with Password and Bearer { #simple-oauth2-with-password-and-bearer }
    
    Now let's build from the previous chapter and add the missing parts to have a complete security flow.
    
    ## Get the `username` and `password` { #get-the-username-and-password }
    
    We are going to use **FastAPI** security utilities to get the `username` and `password`.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:15:41 GMT 2025
    - 9.4K bytes
    - Click Count (0)
Back to Top