- Sort Score
- Result 10 results
- Languages All
Results 871 - 880 of 1,000 for Resync (0.03 sec)
-
internal/logger/target/testlogger/testlogger.go
// // func TestSomething(t *testing.T) { // defer testlogger.T.SetLogTB(t)() // // This cannot be used for parallel tests. package testlogger import ( "context" "fmt" "os" "strings" "sync/atomic" "testing" "github.com/minio/madmin-go/v3/logger/log" "github.com/minio/minio/internal/logger" types "github.com/minio/minio/internal/logger/target/loggertypes" ) const ( logMessage = iota
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4K bytes - Viewed (0) -
docs/ja/docs/tutorial/dependencies/sub-dependencies.md
高度なシナリオでは、「キャッシュされた」値を使うのではなく、同じリクエストの各ステップ(おそらく複数回)で依存関係を呼び出す必要があることがわかっている場合、`Depens`を使用する際に、`use_cache=False`というパラメータを設定することができます。 ```Python hl_lines="1" async def needy_dependency(fresh_value: str = Depends(get_value, use_cache=False)): return {"fresh_value": fresh_value} ``` ## まとめ ここで使われている派手な言葉は別にして、**依存性注入** システムは非常にシンプルです。 *path operation関数*と同じように見えるただの関数です。
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 4.3K bytes - Viewed (0) -
internal/grid/muxserver.go
LastPing: time.Now().Unix(), BaseFlags: c.baseFlags, clientPingInterval: c.clientPingInterval, } // Acknowledge Mux created. // Send async. var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() var ack message ack.Op = OpAckMux ack.Flags = m.BaseFlags ack.MuxID = m.ID m.send(ack) if debugPrint {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 9.7K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
) { bucketName1 := fmt.Sprintf("%s-1", bucketName) const n = 100 start := make(chan struct{}) var ok, errs int var wg sync.WaitGroup var mu sync.Mutex wg.Add(n) for range n { go func() { defer wg.Done() // Sync start. <-start if err := obj.MakeBucket(GlobalContext, bucketName1, MakeBucketOptions{}); err != nil { if _, ok := err.(BucketExists); !ok {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.9K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2RequestTest.java
void testSetTid() { int tid = 12345; testRequest.setTid(tid); assertEquals(tid, testRequest.getTreeId()); } } @Nested @DisplayName("Async Operation Tests") class AsyncOperationTests { @Test @DisplayName("isResponseAsync should return false when asyncId is 0") void testIsResponseAsyncFalse() {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.7K bytes - Viewed (0) -
README.md
```java suggester.suggest() .setQuery("sea") .execute() .done(response -> { // Handle successful response response.getItems().forEach(item -> System.out.println("Async suggestion: " + item.getText()[0]) ); }) .error(throwable -> { // Handle error System.err.println("Error: " + throwable.getMessage()); }); ``` ## Advanced Usage
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Sun Aug 31 03:31:14 UTC 2025 - 12.1K bytes - Viewed (1) -
src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java
ChangeNotificationHandle handle = new ChangeNotificationHandle(directoryPath, leaseKey, directory); activeWatchers.put(directoryPath, handle); // Start async change notification startAsyncNotification(handle); } catch (Exception e) { log.error("Failed to start directory watching for: " + directoryPath, e); } }
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 13.7K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
integrity sha512-+EUsqGPLsM+j/zdChZjsnX51g4XrHFOIXwfnCVPGlQk/k5giakcKsuxCObBRu6DSm9opw/O6slWbJdghQM4bBg== neo-async@^2.6.2: version "2.6.2" resolved "https://registry.yarnpkg.com/neo-async/-/neo-async-2.6.2.tgz#b4aafb93e3aeb2d8174ca53cf163ab7d7308305f" integrity sha512-Yd3UES5mWCSqR+qNT93S3UoYUkqAZ9lLg8a7g9rimsWmYGK8cVToA4/sF3RrshdyV3sAGMXVUmpMYOw+dLpOuw==
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 87.4K bytes - Viewed (0) -
docs/ko/docs/tutorial/dependencies/dependencies-with-yield.md
yield된 값은 *경로 작업* 및 다른 의존성들에 주입되는 값 입니다: {* ../../docs_src/dependencies/tutorial007.py hl[4] *} `yield`문 다음의 코드는 응답을 생성한 후 보내기 전에 실행됩니다: {* ../../docs_src/dependencies/tutorial007.py hl[5:6] *} /// tip | 팁 `async` 함수와 일반 함수 모두 사용할 수 있습니다. **FastAPI**는 일반 의존성과 마찬가지로 각각의 함수를 올바르게 처리할 것입니다. /// ## `yield`와 `try`를 사용하는 의존성 `yield`를 사용하는 의존성에서 `try` 블록을 사용한다면, 의존성을 사용하는 도중 발생한 모든 예외를 받을 수 있습니다.Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sun Feb 09 14:54:09 UTC 2025 - 14.2K bytes - Viewed (0) -
docs/zh/docs/advanced/custom-response.md
如果您有类似文件的对象(例如,由 `open()` 返回的对象),则可以在 `StreamingResponse` 中将其返回。 包括许多与云存储,视频处理等交互的库。 {* ../../docs_src/custom_response/tutorial008.py hl[2,10:12,14] *} /// tip | 小贴士 注意在这里,因为我们使用的是不支持 `async` 和 `await` 的标准 `open()`,我们使用普通的 `def` 声明了路径操作。 /// ### `FileResponse` 异步传输文件作为响应。 与其他响应类型相比,接受不同的参数集进行实例化: * `path` - 要流式传输的文件的文件路径。 * `headers` - 任何自定义响应头,传入字典类型。Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Mon Nov 18 02:25:44 UTC 2024 - 7.5K bytes - Viewed (0)