* Similar to HTTPCallback::OnReceiveData, but thread-safe. */
| 46 | * Similar to HTTPCallback::OnReceiveData, but thread-safe. |
| 47 | */ |
| 48 | void OnReceiveData(std::unique_ptr<char[]> data, size_t length) |
| 49 | { |
| 50 | std::lock_guard<std::mutex> lock(this->mutex); |
| 51 | this->queue.emplace_back(std::move(data), length); |
| 52 | } |
| 53 | |
| 54 | /** |
| 55 | * Process everything on the queue. |
no outgoing calls
no test coverage detected