Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for internalResp (0.24 sec)

  1. internal/grid/muxclient.go

    		}
    	}
    }
    
    // responseCh is the channel to that goes to the requester.
    // internalResp is the channel that comes from the server.
    func (m *muxClient) handleTwowayResponses(responseCh chan<- Response, internalResp <-chan Response) {
    	defer m.parent.deleteMux(false, m.MuxID)
    	defer xioutil.SafeClose(responseCh)
    	for resp := range internalResp {
    		responseCh <- resp
    		m.send(message{Op: OpUnblockSrvMux, MuxID: m.MuxID})
    	}
    }
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
Back to top