(response *http.Response, err error)
| 121 | } |
| 122 | |
| 123 | func (m *MockHttpServer) Respond(response *http.Response, err error) { |
| 124 | if m.Closed { |
| 125 | return // can't respond after closure |
| 126 | } |
| 127 | |
| 128 | atomic.AddInt32(&m.pendingMsgCount, 1) |
| 129 | m.Response <- responseOrError{response: response, error: err} |
| 130 | atomic.AddInt32(&m.pendingMsgCount, -1) |
| 131 | } |
| 132 | |
| 133 | // now we build some higher level methods on top of ReceiveRequest |
| 134 |
no outgoing calls