GenericReceiverConcept.hpp

Go to the documentation of this file.

#ifndef ASIOLIBS_SRC_GENERICRECEIVERCONCEPT_HPP_
#define ASIOLIBS_SRC_GENERICRECEIVERCONCEPT_HPP_
 
#include "iomanager/Receiver.hpp"
 
#include <memory>
 
namespace dunedaq::asiolibs {
 
class GenericReceiverConcept
{
public: 
    struct TypeErasedPayload {          
      std::shared_ptr<const void> owner;     
      const void* data;     
      std::size_t size;
    };
 
    virtual ~GenericReceiverConcept() = default;
    virtual std::optional<TypeErasedPayload> try_receive(dunedaq::iomanager::Receiver::timeout_t timeout) = 0;
};   
 
} // namespace dunedaq::asiolibs
 
#endif // ASIOLIBS_SRC_GENERICRECEIVERCONCEPT_HPP_