21#ifndef HEDGEHOG_IMPLEMENTOR_RECEIVER_H
22#define HEDGEHOG_IMPLEMENTOR_RECEIVER_H
31namespace implementor {
33#ifndef DOXYGEN_SHOULD_SKIP_THIS
37class ImplementorSender;
45 std::unique_ptr<std::set<abstraction::ReceiverAbstraction<Input> *>>
51 abstractReceivers_(std::make_unique<std::set<abstraction::ReceiverAbstraction<Input> *>>()) {}
68 [[nodiscard]]
virtual std::set<abstraction::SenderAbstraction<Input> *>
const &
connectedSenders()
const = 0;
80 virtual void receive(std::shared_ptr<Input> data) = 0;
96 [[nodiscard]]
virtual bool empty()
const = 0;
Core's abstraction to receive a piece of data.
Core abstraction to send data.
Implementor for the ReceiverAbstraction.
virtual void removeSender(abstraction::SenderAbstraction< Input > *sender)=0
Remove a SenderAbstraction.
ImplementorReceiver()
Default constructor.
virtual size_t maxNumberElementsReceived() const =0
Accessor to the maximum number of data waiting to be processed in the queue during the whole executio...
std::set< abstraction::ReceiverAbstraction< Input > * > & receivers()
Accessor to the linked ReceiverAbstraction.
virtual void receive(std::shared_ptr< Input > data)=0
Receive data interface.
virtual bool empty() const =0
Test if the receiver is empty or not.
virtual void initialize(abstraction::ReceiverAbstraction< Input > *receiverAbstraction)
Initialize the implementor Receiver by setting the corresponding abstraction.
std::unique_ptr< std::set< abstraction::ReceiverAbstraction< Input > * > > abstractReceivers_
Set of linked ReceiverAbstraction.
virtual size_t numberElementsReceived() const =0
Accessor to number of data waiting to be processed in the queue.
virtual std::set< abstraction::SenderAbstraction< Input > * > const & connectedSenders() const =0
Accessor to the connected senders.
virtual void addSender(abstraction::SenderAbstraction< Input > *sender)=0
Add a SenderAbstraction.
virtual std::shared_ptr< Input > getInputData()=0
Accessor to a received data.
virtual ~ImplementorReceiver()=default
Default destructor.