Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for respHandler (0.05 sec)

  1. 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)
Back to top