- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for CloseConn (0.25 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/stream.go
closeConnOnce := &sync.Once{} closeConn := func() { closeConnOnce.Do(func() { ws.Close() }) } negotiated := ws.Config().Protocol r.selectedProtocol = negotiated[0] defer close(r.err) defer closeConn() go func() { defer runtime.HandleCrash() // This blocks until the connection is closed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/grpc.go
type grpcCall struct { e *executor getConn grpcConnectionGetter } func (c *grpcCall) makeRequest(ctx context.Context, cfg *Config, requestID int) (string, error) { conn, closeConn, err := c.getConn() if err != nil { return "", err } defer closeConn() // Set the per-request timeout. ctx, cancel := context.WithTimeout(ctx, cfg.timeout) defer cancel() // Add headers to the request context.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 14 19:45:43 UTC 2023 - 4.5K bytes - Viewed (0)