File i_publisher.h

Location: core/communication/i_publisher.h

Classes

• simulation_framework::core::IPublisher

Namespaces

• simulation_framework
• simulation_framework::core

Includes

• core/export/simfwk_core_export.h

Included by

• i_topic.h

Source

#ifndef SIMFWK_CORE_COMMUNICATION_IPUBLISHER_H
#define SIMFWK_CORE_COMMUNICATION_IPUBLISHER_H

#include "core/export/simfwk_core_export.h"
#include <chrono>
#include <memory>
#include <string>
#include <vector>

namespace simulation_framework
{
namespace core
{

class SIMFWK_CORE_API IPublisher
{
  public:
    virtual ~IPublisher() = default;
    virtual void Execute() = 0;
    virtual void Init() = 0;
    virtual bool WaitForSubscriber(std::chrono::milliseconds timeout = std::chrono::milliseconds(60000)) = 0;
    virtual bool WaitForSubscribersInNumberOf(const int subscriber_count,
                                              std::chrono::milliseconds timeout = std::chrono::milliseconds(60000)) = 0;
};

using Publishers = std::vector<std::unique_ptr<IPublisher>>;

}  // namespace core
}  // namespace simulation_framework

#endif  // SIMFWK_CORE_COMMUNICATION_IPUBLISHER_H