sendRequestLoop
(params *startRuntimeParams)
| 107 | |
| 108 | // sendRequestLoop |
| 109 | func (info *RuntimeInfo) sendRequestLoop(params *startRuntimeParams) { |
| 110 | if !info.WithStreamMode { |
| 111 | info.runtimeConn = params.conn |
| 112 | info.runtimeWaitGroup.Add(1) |
| 113 | go info.sendGenericRequestLoop() |
| 114 | } else { |
| 115 | if info.httpClient == nil { |
| 116 | info.httpClient = info.getHTTPClient() |
| 117 | } |
| 118 | info.runtimeWaitGroup.Add(1) |
| 119 | go info.sendHTTPRequestLoop() |
| 120 | } |
| 121 | } |
| 122 | |
| 123 | // sendGenericRequestLoop |
| 124 | func (info *RuntimeInfo) sendGenericRequestLoop() { |
no test coverage detected