first_in_first_out_threaded_observer.h

#pragma once
 
#include <optional>
 
#include "software/multithreading/threaded_observer.hpp"
 
template <typename T>
class FirstInFirstOutThreadedObserver : public ThreadedObserver<T>
{
   public:
    FirstInFirstOutThreadedObserver() : ThreadedObserver<T>(){};
 
    explicit FirstInFirstOutThreadedObserver<T>(size_t buffer_size,
                                                bool log_buffer_full = true)
        : ThreadedObserver<T>(buffer_size, log_buffer_full){};
    std::optional<T> getNextValue(const Duration& max_wait_time) final override;
};
 
template <typename T>
std::optional<T> FirstInFirstOutThreadedObserver<T>::getNextValue(
    const Duration& max_wait_time)
{
    return this->popLeastRecentlyReceivedValue(max_wait_time);
}