| 30 | } |
| 31 | |
| 32 | template<class T> inline void MessageBuffer<T>::AppendMessage(const T &message) |
| 33 | { |
| 34 | std::lock_guard<std::mutex> lock(_mutex); |
| 35 | _buffer.emplace_back(message); |
| 36 | } |
| 37 | |
| 38 | template<class T> inline std::optional<T> MessageBuffer<T>::ConsumeMessage() |
| 39 | { |