Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 421 - 430 of 722 for Completer (0.06 seconds)

  1. docs/zh-hant/docs/fastapi-cli.md

         <span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span>  Waiting for application startup.
         <span style="background-color:#007166"><font color="#D3D7CF"> INFO </font></span>  Application startup complete.
    ```
    
    </div>
    
    /// tip
    
    在生產環境請改用 `fastapi run`,不要用 `fastapi dev`。🚀
    
    ///
    
    在內部,**FastAPI CLI** 使用 [Uvicorn](https://www.uvicorn.dev),這是一個高效能、適用於生產環境的 ASGI 伺服器。😎
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 17:05:38 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  2. cmd/erasure-heal_test.go

    			staleWriters[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize())
    		}
    
    		// test case setup is complete - now call Heal()
    		err = erasure.Heal(t.Context(), staleWriters, readers, test.size, nil)
    		closeBitrotReaders(readers)
    		closeBitrotWriters(staleWriters)
    		if err != nil && !test.shouldFail {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  3. src/test/java/jcifs/netbios/SessionRequestPacketTest.java

            int bytesWritten = packet.writeTrailerWireFormat(dst, 0);
    
            assertTrue(bytesWritten > 68); // Should be larger due to scope
        }
    
        @Test
        @DisplayName("readTrailerWireFormat should read complete packet data")
        void testReadTrailerWireFormatSuccess() throws IOException {
            SessionRequestPacket writePacket =
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  4. docs/contribute/concurrency.md

    Since HTTP requests frequently happen in parallel, connection pooling must be thread-safe.
    
    These are the primary classes involved with establishing, sharing, and terminating connections:
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

          )
        serverIpv4.protocols = listOf(Protocol.H2_PRIOR_KNOWLEDGE)
        serverIpv6.protocols = listOf(Protocol.H2_PRIOR_KNOWLEDGE)
    
        // Yield the first IP address so the second IP address completes first.
        val firstConnectLatch = CountDownLatch(1)
        val socketFactory =
          object : DelegatingSocketFactory(SocketFactory.getDefault()) {
            var first = true
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/PreauthIntegrityService.java

                context.invalidate();
                throw new CIFSException("Failed to update preauth integrity hash for session " + sessionId, e);
            }
        }
    
        /**
         * Validates the preauth integrity for completed negotiation.
         *
         * @param sessionId the session identifier
         * @param expectedHash the expected final hash
         * @return true if validation passes
         * @throws CIFSException if validation fails
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  7. internal/config/lambda/target/webhook.go

    	// No network failure i.e response from the target means its up
    	return true, nil
    }
    
    // Stat - returns lambda webhook target statistics such as
    // current calls in progress, successfully completed functions
    // failed functions.
    func (target *WebhookTarget) Stat() event.TargetStat {
    	return event.TargetStat{
    		ID:             target.id,
    		ActiveRequests: atomic.LoadInt64(&target.activeRequests),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jul 08 21:39:49 GMT 2024
    - 6.7K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilCommon.kt

    internal fun BufferedSource.readMedium(): Int =
      (
        readByte() and 0xff shl 16
          or (readByte() and 0xff shl 8)
          or (readByte() and 0xff)
      )
    
    /** Run [block] until it either throws an [IOException] or completes. */
    internal inline fun ignoreIoExceptions(block: () -> Unit) {
      try {
        block()
      } catch (_: IOException) {
      }
    }
    
    internal fun Buffer.skipAll(b: Byte): Int {
      var count = 0
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon May 05 16:01:00 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

              }
            };
    
        recursiveCache = CacheBuilder.newBuilder().weakKeys().weakValues().build(recursiveLoader);
        cacheRef.set(recursiveCache);
    
        // tells the test when the computation has completed
        CountDownLatch doneSignal = new CountDownLatch(1);
    
        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 13.1K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

              }
            };
    
        recursiveCache = CacheBuilder.newBuilder().weakKeys().weakValues().build(recursiveLoader);
        cacheRef.set(recursiveCache);
    
        // tells the test when the computation has completed
        CountDownLatch doneSignal = new CountDownLatch(1);
    
        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 13.1K bytes
    - Click Count (0)
Back to Top