- Sort Score
- Num 10 results
- Language All
Results 421 - 430 of 722 for Completer (0.06 seconds)
-
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) -
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) -
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) -
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) -
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 = trueCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.6K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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)