| 60 | m_timeoutMs = milliseconds; |
| 61 | } |
| 62 | size_t TestSocket::ReadServer(std::vector<uint8_t> & destination) |
| 63 | { |
| 64 | std::unique_lock lock(m_outputMutex); |
| 65 | m_outputCondition.wait_for(lock, std::chrono::milliseconds(m_timeoutMs), [this]() { return !m_output.empty(); }); |
| 66 | |
| 67 | size_t const outputSize = m_output.size(); |
| 68 | destination.insert(destination.end(), m_output.begin(), m_output.end()); |
| 69 | m_output.clear(); |
| 70 | return outputSize; |
| 71 | } |
| 72 | } // namespace tests_support |
| 73 | } // namespace platform |