- Sort Score
- Result 10 results
- Languages All
Results 281 - 290 of 517 for bgwait (0.04 sec)
-
docs/fr/docs/index.md
return {"item_id": item_id, "q": q} ``` <details markdown="1"> <summary>Ou utilisez <code>async def</code> ...</summary> Si votre code utilise `async` / `await`, utilisez `async def` : ```Python hl_lines="9 14" from typing import Union from fastapi import FastAPI app = FastAPI() @app.get("/") async def read_root():
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:49:48 UTC 2025 - 22K bytes - Viewed (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.put("discovery.type", "single-node"); }).build(newConfigs().clusterName(clusterName).numOfNode(1)); // wait for yellow status runner.ensureYellow(); System.setProperty(FesenClient.HTTP_ADDRESS, "localhost:" + runner.node().settings().get("http.port", "9201")); super.setUp(); // logging
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 7.7K bytes - Viewed (0) -
cmd/sftp-server-driver.go
return nil, err } return obj, nil } // TransferError will catch network errors during transfer. // When TransferError() is called Close() will also // be called, so we do not need to Wait() here. func (w *writerAt) TransferError(err error) { _ = w.w.CloseWithError(err) _ = w.r.CloseWithError(err) w.err = err } func (w *writerAt) Close() (err error) { switch {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0) -
src/test/java/jcifs/util/AuthenticationRateLimiterTest.java
try { rateLimiter.checkAttempt(username, ip); fail("Should be locked out"); } catch (SmbException e) { // Expected } // Wait for lockout to expire Thread.sleep(2100); // Lockout is 2 seconds in test setup // Should be allowed again assertTrue(rateLimiter.checkAttempt(username, ip), "Should be allowed after lockout expiry");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.8K bytes - Viewed (0) -
docs/em/docs/advanced/custom-response.md
, ⚫️ 🚂 🔢 👈 📨 "🏭" 👷 🕳 🙆 🔘. 🔨 ⚫️ 👉 🌌, 👥 💪 🚮 ⚫️ `with` 🍫, & 👈 🌌, 🚚 👈 ⚫️ 📪 ⏮️ 🏁. /// tip 👀 👈 📥 👥 ⚙️ 🐩 `open()` 👈 🚫 🐕🦺 `async` & `await`, 👥 📣 ➡ 🛠️ ⏮️ 😐 `def`. /// ### `FileResponse` 🔁 🎏 📁 📨. ✊ 🎏 ⚒ ❌ 🔗 🌘 🎏 📨 🆎: * `path` - 📁 📁 🎏. * `headers` - 🙆 🛃 🎚 🔌, 📖.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 9.4K bytes - Viewed (0) -
docs/bucket/replication/delete-replication.sh
./mc cp README.md myminio1/foobucket/dir/file versionId="$(./mc ls --json --versions myminio1/foobucket/dir/ | jq -r .versionId)" kill ${pid2} && wait ${pid2} || true aws s3api --endpoint-url http://localhost:9001 delete-object --bucket foobucket --key dir/file --version-id "$versionId" out="$(./mc ls myminio1/foobucket/dir/)" if [ "$out" != "" ]; then
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 3.9K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* <a href="https://developer.android.com/studio/build/shrink-code">R8 and Proguard</a>. * <li>It doesn't offer a way to wait for multiple events before taking action. For example, it * doesn't offer a way to wait for multiple producers to all report that they're "ready," nor * does it offer a way to batch multiple events from a single producer together.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
/** * Context object containing crawler state and configuration. */ protected CrawlerContext crawlerContext; /** * Flag indicating whether to wait on folder operations. */ protected boolean noWaitOnFolder = false; /** * Increments the active thread count. */ protected void startCrawling() {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 20.4K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
this.inFlightLookups.add(name); return null; } while (this.inFlightLookups.contains(name)) { try { this.inFlightLookups.wait(); } catch (final InterruptedException e) { log.trace("Interrupted", e); } } } obj = getCachedAddress(name);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 38.5K bytes - Viewed (0) -
cmd/erasure-healing.go
Name: volInfo.Name, Created: volInfo.Created, count: 1, }, false }) } return nil }, index) } if err := reduceReadQuorumErrs(ctx, g.Wait(), bucketMetadataOpIgnoredErrs, readQuorum); err != nil { return err } healBuckets.Range(func(volName string, volInfo VolInfo) bool { if volInfo.count < readQuorum { healBuckets.Delete(volName) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.6K bytes - Viewed (0)