## On this page

  

 

 # i\_publisher

 Last update: 16.07.2025 

<a name="l00001"></a> 1 

<a name="l00005"></a> 5 

<a name="l00006"></a> 6 \#pragma once

<a name="l00007"></a> 7 

<a name="l00008"></a> 8 \#include &lt;chrono&gt;

<a name="l00009"></a> 9 \#include &lt;memory&gt;

<a name="l00010"></a> 10 \#include &lt;string&gt;

<a name="l00011"></a> 11 \#include &lt;vector&gt;

<a name="l00012"></a> 12 

<a name="l00013"></a> 13 namespace [simulation\_framework](namespacesimulation__framework.xhtml)

<a name="l00014"></a> 14 {

<a name="l00015"></a> 15 namespace [core](namespacecore.xhtml)

<a name="l00016"></a> 16 {

<a name="l00017"></a> 17 

<a name="l00018"></a> 18 class IPublisher

<a name="l00019"></a> 19 {

<a name="l00020"></a> 20 public:

<a name="l00021"></a> 21 virtual ~IPublisher() = default;

<a name="l00022"></a> 22 virtual void Execute() = 0;

<a name="l00023"></a> 23 virtual void Init() = 0;

<a name="l00024"></a> 24 virtual bool WaitForSubscriber(std::chrono::milliseconds timeout = std::chrono::milliseconds(60000)) = 0;

<a name="l00025"></a> 25 virtual bool WaitForSubscribersInNumberOf(const int subscriber_count,

<a name="l00026"></a> 26 std::chrono::milliseconds timeout = std::chrono::milliseconds(60000)) = 0;

<a name="l00027"></a> 27 };

<a name="l00028"></a> 28 

<a name="l00029"></a> 29 using Publishers = std::vector&lt;std::unique_ptr&lt;IPublisher&gt;&gt;;

<a name="l00030"></a> 30 

<a name="l00031"></a> 31 } // namespace core

<a name="l00032"></a> 32 } // namespace simulation\_framework