RscImplReadEnumerator.hxx

 
//
//  Copyright Phoenix Contact GmbH & Co. KG
//
#pragma once
#include "Arp/Base/Core/Arp.hpp"
#include "Arp/Base/Rsc/Commons/IRscReadEnumerator.hxx"
#include "Arp/Base/Commons/Exceptions/InvalidOperationException.hpp"
 
namespace Arp::Base::Rsc::Commons::Services
{
 
template<class T>
class RscImplReadEnumerator : public IRscReadEnumerator<T>
{
public: // usings
    using BeginFunction     = std::function<size_t()>;              
    using NextFunction      = std::function<bool(T&)>;              
    using NextArrayFunction = std::function<bool(RscArrayReader&)>; 
    using EndFunction       = std::function<void()>;                
 
public: // construction
    RscImplReadEnumerator(void);
 
public: // properties
    BeginFunction       Begin;      
    NextFunction        Next;       
    NextArrayFunction   NextArray;  
    EndFunction         End;        
 
public: // overridden operations from IRscReadEnumerator interface
    size_t  BeginRead(void)override;
    bool    ReadNext(T&)override;
    bool    ReadNext(RscArrayReader& current)override;
    void    EndRead(void)override;
};
 
// inline methods of class RscImplReadEnumerator
 
template<class T>
inline RscImplReadEnumerator<T>::RscImplReadEnumerator() = default;
 
template<class T>
inline size_t RscImplReadEnumerator<T>::BeginRead()
{
    if(!this->Begin)
    {
        throw InvalidOperationException("Begin callback is not set.");
    }
    return this->Begin();
}
 
template<class T>
inline bool RscImplReadEnumerator<T>::ReadNext(T& current)
{
    if(!this->Next)
    {
        throw InvalidOperationException("Next callback is not set.");
    }
    return this->Next(current);
}
 
template<class T>
inline bool RscImplReadEnumerator<T>::ReadNext(RscArrayReader& current)
{
    if (!this->NextArray)
    {
        throw InvalidOperationException("NextArray callback is not set.");
    }
    return this->NextArray(current);
}
 
template<class T>
inline void RscImplReadEnumerator<T>::EndRead()
{
    if(this->End)
    {
        this->End();
    }
}
 
} // end of namespace Arp::Base::Rsc::Commons::Services