Home
last modified time | relevance | path

Searched refs:closeCh (Results 176 – 200 of 593) sorted by relevance

12345678910>>...24

/dports/security/vault/vault-1.8.2/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/sysutils/hared/hared-hare-1.0-45-g8341d8a/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go24 closeCh chan struct{} member
53 closeCh: make(chan struct{}),
92 case <-b.closeCh:
102 close(b.closeCh)
/dports/www/devd/devd-0.9/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/gorilla/websocket/websocket-1.4.2/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/gorilla/websocket/
H A Dconn_broadcast_test.go22 closeCh chan struct{} member
51 closeCh: make(chan struct{}),
90 case <-b.closeCh:
100 close(b.closeCh)
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/runtimevar/filevar/
H A Dfilevar.go157 closeCh: make(chan error),
206 closeCh chan error member
255 w.closeCh <- notifier.Close()
292 w.closeCh <- notifier.Close()
317 err := <-w.closeCh
320 close(w.closeCh)
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/runtimevar/filevar/
H A Dfilevar.go157 closeCh: make(chan error),
206 closeCh chan error member
255 w.closeCh <- notifier.Close()
292 w.closeCh <- notifier.Close()
317 err := <-w.closeCh
320 close(w.closeCh)
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/runtimevar/filevar/
H A Dfilevar.go157 closeCh: make(chan error),
206 closeCh chan error member
255 w.closeCh <- notifier.Close()
292 w.closeCh <- notifier.Close()
317 err := <-w.closeCh
320 close(w.closeCh)
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/runtimevar/filevar/
H A Dfilevar.go157 closeCh: make(chan error),
206 closeCh chan error member
255 w.closeCh <- notifier.Close()
292 w.closeCh <- notifier.Close()
317 err := <-w.closeCh
320 close(w.closeCh)
/dports/misc/fq/fq-0.0.2/internal/ctxstack/
H A Dctxstack.go16 closeCh chan struct{} member
22 s := &Stack{closeCh: stopCh}
46 close(s.closeCh)
/dports/net/goreplay/goreplay-1.2.0/
H A Dgor.go76 closeCh := make(chan int)
77 emitter := NewEmitter(closeCh)
84 close(closeCh)
93 case <-closeCh:
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/centrifugal/centrifuge/
H A Dhandler_sockjs.go22 closeCh chan struct{} member
29 closeCh: make(chan struct{}),
60 case <-t.closeCh:
72 case <-t.closeCh:
93 close(t.closeCh)
/dports/devel/taskctl/taskctl-1.4.2/pkg/output/
H A Dcockpit_test.go15 closeCh = make(chan bool)
16 dec := newCockpitOutputWriter(&task.Task{Name: "task1"}, &b, closeCh)
48 close(closeCh)
H A Doutput.go18 var closeCh = make(chan bool) var
46 o.decorator = newCockpitOutputWriter(t, stdout, closeCh)
78 close(closeCh)
/dports/net/cloudquery/cloudquery-0.16.0/vendor/google.golang.org/grpc/xds/internal/server/
H A Dlistener_wrapper_test.go186 closeCh *testutils.Channel member
198 fl.closeCh.Send(nil)
213 closeCh *testutils.Channel member
225 fc.closeCh.Send(nil)
236 closeCh: testutils.NewChannel(),
466 closeCh: testutils.NewChannel(),
469 if _, err := fc.closeCh.Receive(ctx); err != nil {
478 closeCh: testutils.NewChannel(),
/dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/google.golang.org/grpc/xds/internal/server/
H A Dlistener_wrapper_test.go186 closeCh *testutils.Channel member
198 fl.closeCh.Send(nil)
213 closeCh *testutils.Channel member
225 fc.closeCh.Send(nil)
236 closeCh: testutils.NewChannel(),
466 closeCh: testutils.NewChannel(),
469 if _, err := fc.closeCh.Receive(ctx); err != nil {
478 closeCh: testutils.NewChannel(),
/dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/grpc/xds/internal/server/
H A Dlistener_wrapper_test.go186 closeCh *testutils.Channel member
198 fl.closeCh.Send(nil)
213 closeCh *testutils.Channel member
225 fc.closeCh.Send(nil)
236 closeCh: testutils.NewChannel(),
466 closeCh: testutils.NewChannel(),
469 if _, err := fc.closeCh.Receive(ctx); err != nil {
478 closeCh: testutils.NewChannel(),
/dports/www/grafana8/grafana-8.3.6/vendor/google.golang.org/grpc/xds/internal/server/
H A Dlistener_wrapper_test.go186 closeCh *testutils.Channel member
198 fl.closeCh.Send(nil)
213 closeCh *testutils.Channel member
225 fc.closeCh.Send(nil)
236 closeCh: testutils.NewChannel(),
466 closeCh: testutils.NewChannel(),
469 if _, err := fc.closeCh.Receive(ctx); err != nil {
478 closeCh: testutils.NewChannel(),
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/vendor/github.com/Microsoft/go-winio/
H A Dpipe.go136 closeCh chan int member
174 case <-l.closeCh:
190 case <-l.closeCh:
238 closeCh: make(chan int),
271 case l.closeCh <- 1:

12345678910>>...24