| 1093 | } |
| 1094 | } |
| 1095 | bool write(T && data) { |
| 1096 | std::lock_guard<std::mutex> lk(mutex); |
| 1097 | if (reader_closed.load()) { |
| 1098 | return false; // broken pipe |
| 1099 | } |
| 1100 | queue.push(std::move(data)); |
| 1101 | cv.notify_one(); |
| 1102 | return true; |
| 1103 | } |
| 1104 | }; |
| 1105 | |
| 1106 | static std::string to_lower_copy(const std::string & value) { |
no test coverage detected