- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,571 for chan2 (0.04 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/with_retry_after_test.go
return newChannel(true) }, requestURL: "/api/v1/namespaces", userAgent: "foo", handlerInvoked: 0, closeExpected: "close", retryAfterExpected: "5", statusCodeExpected: http.StatusTooManyRequests, }, { name: "retry-after enabled, request is exempt(/metrics)", shutdownDelayDurationElapsedFn: func() <-chan struct{} {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 31 14:10:46 UTC 2021 - 6.1K bytes - Viewed (0) -
src/internal/types/testdata/fixedbugs/issue51229.go
func ch1[P chan<- int]() (_ P) { return } // core(P) == chan<- int (single type, no tilde) func ch2[P ~chan int]() { return } // core(P) == ~chan<- int (tilde) func ch3[P chan E, E any](E) { return } // core(P) == chan<- E (single type, no tilde) func ch4[P chan E | ~chan<- E, E any](E) { return } // core(P) == ~chan<- E (tilde)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 17 19:54:27 UTC 2023 - 4.8K bytes - Viewed (0) -
src/net/pipe.go
// Successful receive on rdRx is always followed by send on rdTx. rdRx <-chan []byte rdTx chan<- int // Used by local Write to interact with remote Read. // Successful send on wrTx is always followed by receive on wrRx. wrTx chan<- []byte wrRx <-chan int once sync.Once // Protects closing localDone localDone chan struct{} remoteDone <-chan struct{} readDeadline pipeDeadline writeDeadline pipeDeadline
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
test/parentype.go
package main func f(interface{}) func g() {} func main() { f(map[string]string{"a":"b","c":"d"}) f([...]int{1,2,3}) f(map[string]func(){"a":g,"c":g}) f(make(chan(<-chan int))) f(make(chan<-(chan int)))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 23 23:30:39 UTC 2012 - 424 bytes - Viewed (0) -
test/fixedbugs/issue8017.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 540 bytes - Viewed (0) -
src/cmd/cgo/internal/teststdio/testdata/chain.go
const N = 10 const R = 5 func link(left chan<- int, right <-chan int) { // Keep the links in dedicated operating system // threads, so that this program tests coordination // between pthreads and not just goroutines. runtime.LockOSThread() for { v := <-right stdio.Stdout.WriteString(strconv.Itoa(v) + "\n") left <- 1 + v } } func main() { leftmost := make(chan int) var left chan int right := leftmost
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 914 bytes - Viewed (0) -
src/go/internal/gcimporter/testdata/exports.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 1.5K bytes - Viewed (0) -
test/func5.go
} var f func(int, int) int func add(x, y int) int { return x + y } func fn() func(int, int) int { return f } var fc func(int, int, chan int) func addc(x, y int, c chan int) { c <- x+y } func fnc() func(int, int, chan int) { return fc } func three(x int) { if x != 3 { println("wrong val", x) panic("fail") } } var notmain func()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Feb 19 03:28:53 UTC 2012 - 1.5K bytes - Viewed (0) -
pkg/kube/krt/sync.go
package krt import "istio.io/istio/pkg/kube" type Syncer interface { WaitUntilSynced(stop <-chan struct{}) bool HasSynced() bool } var ( _ Syncer = channelSyncer{} _ Syncer = pollSyncer{} ) type channelSyncer struct { name string synced <-chan struct{} } func (c channelSyncer) WaitUntilSynced(stop <-chan struct{}) bool { return waitForCacheSync(c.name, stop, c.synced) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 03 14:25:07 UTC 2024 - 1.8K bytes - Viewed (0) -
test/sieve.go
package main // Send the sequence 2, 3, 4, ... to channel 'ch'. func Generate(ch chan<- int) { for i := 2; ; i++ { ch <- i // Send 'i' to channel 'ch'. } } // Copy the values from channel 'in' to channel 'out', // removing those divisible by 'prime'. func Filter(in <-chan int, out chan<- int, prime int) { for { i := <-in // Receive value of new variable 'i' from 'in'. if i%prime != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 24 00:48:19 UTC 2012 - 1K bytes - Viewed (0)