Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 254 for chanOf (0.14 sec)

  1. pkg/proxy/endpointschangetracker_test.go

    			}
    
    			for _, change := range changes {
    				// All of the test cases have 0 or 1 changes, so if we're
    				// here, then expectedChanges[0] is what we expect.
    				expectedChange := tc.expectedChanges[0]
    
    				if !reflect.DeepEqual(change.previous, expectedChange.previous) {
    					t.Errorf("Expected change.previous: %+v, got: %+v", expectedChange.previous, change.previous)
    				}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 79.9K bytes
    - Viewed (0)
  2. platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_8.adoc

    ==== Change the encoding of daemon log files
    In previous versions of Gradle, the daemon log file, located at `$<<directory_layout.adoc#dir:gradle_user_home,GRADLE_USER_HOME>>/daemon/{gradleVersion}/`, was encoded with the default JVM encoding.
    To prevent clients that may use different default encoding from reading data incorrectly, this file is now always encoded with UTF-8.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 17:01:07 UTC 2024
    - 90.7K bytes
    - Viewed (0)
  3. tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc

                                     llvm::ArrayRef<Type> updated_argument_types,
                                     llvm::ArrayRef<Type> updated_result_types) {
      // Change `func`'s argument type to `unranked_argument_types`. If its
      // return types contain a `DT_VARIANT`, change it to the unranked type
      // derived from the corresponding argument.
      rewriter.modifyOpInPlace(func, [&] {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jun 11 20:00:43 UTC 2024
    - 70.7K bytes
    - Viewed (0)
  4. src/cmd/go/internal/test/test.go

    		runs = append(runs, runTest)
    		prints = append(prints, printTest)
    	}
    
    	// Order runs for coordinating start JSON prints.
    	ch := make(chan struct{})
    	close(ch)
    	for _, a := range runs {
    		if r, ok := a.Actor.(*runTestActor); ok {
    			r.prev = ch
    			ch = make(chan struct{})
    			r.next = ch
    		}
    	}
    
    	// Ultimately the goal is to print the output.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 14:34:32 UTC 2024
    - 71.9K bytes
    - Viewed (0)
  5. src/net/http/transport.go

    	pconn = &persistConn{
    		t:             t,
    		cacheKey:      cm.key(),
    		reqch:         make(chan requestAndChan, 1),
    		writech:       make(chan writeRequest, 1),
    		closech:       make(chan struct{}),
    		writeErrCh:    make(chan error, 1),
    		writeLoopDone: make(chan struct{}),
    	}
    	trace := httptrace.ContextClientTrace(ctx)
    	wrapErr := func(err error) error {
    		if cm.proxyURL != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    type immediateCloseWatcher struct {
    	result chan watch.Event
    }
    
    func newImmediateCloseWatcher() *immediateCloseWatcher {
    	watcher := &immediateCloseWatcher{result: make(chan watch.Event)}
    	close(watcher.result)
    	return watcher
    }
    
    // Implements watch.Interface.
    func (c *immediateCloseWatcher) ResultChan() <-chan watch.Event {
    	return c.result
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  7. plugin/pkg/admission/resourcequota/admission_test.go

    	return createHandlerWithConfig(kubeClient, informerFactory, nil, stopCh)
    }
    
    func createHandlerWithConfig(kubeClient kubernetes.Interface, informerFactory informers.SharedInformerFactory, config *resourcequotaapi.Configuration, stopCh chan struct{}) (*resourcequota.QuotaAdmission, error) {
    	if config == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 84.1K bytes
    - Viewed (0)
  8. platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_7.adoc

    ==== Changing test framework after setting test framework options is now an error
    
    When configuring the built-in test task for Java, Groovy, and Scala projects, Gradle no longer allows you to
    change the test framework used by the `Test` task after configuring options.
    This was deprecated since it silently discarded configuration in some cases.
    
    The following code example now produces an error:
    ```
    test {
       options {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 01 15:00:23 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  9. src/cmd/dist/build.go

    // installed maps from a dir name (as given to install) to a chan
    // closed when the dir's package is installed.
    var installed = make(map[string]chan struct{})
    var installedMu sync.Mutex
    
    func install(dir string) {
    	<-startInstall(dir)
    }
    
    func startInstall(dir string) chan struct{} {
    	installedMu.Lock()
    	ch := installed[dir]
    	if ch == nil {
    		ch = make(chan struct{})
    		installed[dir] = ch
    		go runInstall(dir, ch)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 20 18:34:40 UTC 2024
    - 54K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/types2/api_test.go

    		},
    		{`package t3; type C[T any] interface{chan<- T}; func f[T any, P C[T], Q C[[]*P]]() []T { return nil }; func _() { _ = f[int] }`,
    			[]testInst{
    				{`C`, []string{`T`}, `interface{chan<- T}`},
    				{`C`, []string{`[]*P`}, `interface{chan<- []*P}`},
    				{`f`, []string{`int`, `chan<- int`, `chan<- []*chan<- int`}, `func() []int`},
    			},
    		},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 20:08:23 UTC 2024
    - 93.3K bytes
    - Viewed (0)
Back to top