Method store

proxycore/requests.go:66–74

(request Request)

}

func (p *pendingRequests) store(request Request) int16 {
	select {
	case stream := <-p.streams:
		p.pending.Store(stream, request)
		return stream
	default:
		return -1
	}
}

func (p *pendingRequests) loadAndDelete(stream int16) Request {
	request, ok := p.pending.LoadAndDelete(stream)