- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for respHandler (0.05 sec)
-
internal/grid/muxclient.go
func (m *muxClient) addErrorNonBlockingClose(respHandler chan<- Response, err error) { m.respMu.Lock() defer m.respMu.Unlock() if !m.closed { m.respErr.Store(&err) // Do not block. select { case respHandler <- Response{Err: err}: xioutil.SafeClose(respHandler) default: go func() { respHandler <- Response{Err: err} xioutil.SafeClose(respHandler) }() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0)