Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 1,043 for channel (0.1 sec)

  1. tests/update_test.go

    	if user1UpdatedAt.Format(time.RFC1123Z) == result.UpdatedAt.Format(time.RFC1123Z) {
    		t.Fatalf("user's updated at should be changed, expects: %+v, got: %+v", user1UpdatedAt, result.UpdatedAt)
    	}
    
    	if user2UpdatedAt.Format(time.RFC1123Z) == user2.UpdatedAt.Format(time.RFC1123Z) {
    		t.Fatalf("user's updated at should be changed, expects: %+v, got: %+v", user2UpdatedAt, user2.UpdatedAt)
    	}
    
    	DB.First(&result)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Dec 04 03:50:58 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  2. internal/dsync/dsync_test.go

    	if testing.Short() {
    		t.Skip("skipping test in short mode.")
    	}
    
    	dm := NewDRWMutex(ds, "aap")
    	dm.refreshInterval = testDrwMutexRefreshInterval
    
    	ctx, cancel := context.WithCancel(context.Background())
    
    	if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Make it run twice.
    	timer := time.NewTimer(testDrwMutexRefreshInterval * 2)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Service.java

       * Registers a {@link Listener} to be {@linkplain Executor#execute executed} on the given
       * executor. The listener will have the corresponding transition method called whenever the
       * service changes state. The listener will not have previous state changes replayed, so it is
       * suggested that listeners are added before the service starts.
       *
       * <p>{@code addListener} guarantees execution ordering across calls to a given listener but not
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  4. docs/fr/docs/tutorial/query-params-str-validations.md

    Validateurs et métadonnées génériques:
    
    * `alias`
    * `title`
    * `description`
    * `deprecated`
    
    Validateurs spécifiques aux chaînes de caractères :
    
    * `min_length`
    * `max_length`
    * `regex`
    
    Parmi ces exemples, vous avez pu voir comment déclarer des validateurs pour les chaînes de caractères.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 17:14:38 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/cni-watcher_test.go

    		PodName:      "pod-bingo",
    		PodNamespace: "funkyns",
    		IPs: []IPConfig{{
    			Address: *addr,
    		}},
    	}
    
    	setupLogging()
    	NodeName = "testnode"
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "pod-bingo",
    			Namespace: "funkyns",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. .github/workflows/ci.yml

                java: 21
                root-pom: pom.xml
        runs-on: ${{ matrix.os }}
        env:
          ROOT_POM: ${{ matrix.root-pom }}
        steps:
          # Cancel any previous runs for the same branch that are still running.
          - name: 'Cancel previous runs'
            uses: styfle/cancel-workflow-action@85880fa0301c86cca9da44039ee3bb12d3bedbfa # 0.12.1
            with:
              access_token: ${{ github.token }}
          - name: 'Check out repository'
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 29 18:53:45 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.12.md

        - [Other notable changes](#other-notable-changes)
    - [v1.12.9](#v1129)
      - [Downloads for v1.12.9](#downloads-for-v1129)
        - [Client Binaries](#client-binaries-1)
        - [Server Binaries](#server-binaries-1)
        - [Node Binaries](#node-binaries-1)
      - [Changelog since v1.12.8](#changelog-since-v1128)
        - [Other notable changes](#other-notable-changes-1)
    - [v1.12.8](#v1128)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Feb 06 06:04:15 UTC 2020
    - 293.8K bytes
    - Viewed (0)
  8. internal/config/lambda/target/webhook.go

    	ctx, cancel := context.WithCancel(ctx)
    
    	target := &WebhookTarget{
    		id:         event.TargetID{ID: id, Name: "webhook"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		transport:  transport,
    		cancel:     cancel,
    		cancelCh:   ctx.Done(),
    	}
    
    	return target, nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

      }
    
      public void testListenerCalledOnCancelFromRunning() throws Exception {
        exec.execute(task);
        runLatch.await();
    
        // Task has started up, cancel it while it's running.
        task.cancel(true);
        assertTrue(task.isDone());
        assertTrue(task.isCancelled());
        assertEquals(1, taskLatch.getCount());
    
        // Wait for the listeners to be called.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. internal/grid/benchmark_test.go

    		for par := 1; par <= 32; par *= 2 {
    			b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
    				defer timeout(60 * time.Second)()
    				ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    				defer cancel()
    				b.ReportAllocs()
    				b.SetBytes(int64(len(payload) * 2))
    				b.ResetTimer()
    				t := time.Now()
    				var ops int64
    				var lat int64
    				b.SetParallelism(par)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
Back to top