transport.hpp

Go to the documentation of this file.

#pragma once
 
 
#include <conduit/envelope.hpp>
 
#include <commons/prioritized.hpp>
 
#include <cstdint>
#include <functional>
#include <utility>
 
namespace conduit {
 
class Bus;
 
enum class TransportScope : std::uint8_t { Local, Remote };
 
using InboundSink = std::function<void(const EventEnvelopeView&)>;
 
class Transport : public comms::Prioritized {
public:
    Transport() = default;
    Transport(const Transport&) = delete;
    Transport(Transport&&) noexcept = default;
    Transport& operator=(const Transport&) = delete;
    Transport& operator=(Transport&&) noexcept = default;
    ~Transport() override = default;
 
    [[nodiscard]] virtual TransportScope scope() const noexcept = 0;
 
    virtual void attach(Bus& bus);
 
    virtual void attach_with_sink(Bus& bus, InboundSink sink) {
        bus_ = &bus;
        inbound_sink_ = std::move(sink);
    }
 
    virtual void detach() noexcept {}
    virtual void dispatch(const EventEnvelopeView&) = 0;
    virtual void flush() {}
 
protected:
    void deliver_inbound(const EventEnvelopeView& v) const {
        if (inbound_sink_) {
            inbound_sink_(v);
        }
    }
 
    [[nodiscard]] Bus* bus() const noexcept {
        return bus_;
    }
 
private:
    Bus* bus_ = nullptr;
    InboundSink inbound_sink_;
};
 
}  // namespace conduit