Search Options

Results per page
Sort
Preferred Languages
Advance

Results 871 - 880 of 1,000 for Resync (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top