last_in_first_out_threaded_observer.h

#pragma once
#include "software/multithreading/threaded_observer.hpp"
 
template <typename T>
class LastInFirstOutThreadedObserver : public ThreadedObserver<T>
{
   public:
    LastInFirstOutThreadedObserver() : ThreadedObserver<T>(){};
    explicit LastInFirstOutThreadedObserver<T>(size_t buffer_size)
        : ThreadedObserver<T>(buffer_size){};
    std::optional<T> getNextValue(const Duration& max_wait_time) final;
};
 
template <typename T>
std::optional<T> LastInFirstOutThreadedObserver<T>::getNextValue(
    const Duration& max_wait_time)
{
    return this->popMostRecentlyReceivedValue(max_wait_time);
}