Pipe.h

Go to the documentation of this file.

 
#ifndef QB_PROXYPIPE_H
#define QB_PROXYPIPE_H
#include "ActorId.h"
#include "Event.h"
 
namespace qb {

class Pipe {
    friend class VirtualCore;
 
    VirtualPipe *pipe;
    ActorId      dest;
    ActorId      source;
 
    Pipe(VirtualPipe &i_pipe, ActorId i_dest, ActorId i_source) noexcept
        : pipe(&i_pipe)
        , dest(i_dest)
        , source(i_source) {}
 
public:
    Pipe()                        = default;
    Pipe(Pipe const &)            = default;
    Pipe &operator=(Pipe const &) = default;

    template <typename _Event, typename... _Args>
    _Event &push(_Args &&...args) const noexcept;

    template <typename _Event, typename... _Args>
    [[nodiscard]] _Event &allocated_push(std::size_t size,
                                         _Args &&...args) const noexcept;

    [[nodiscard]] inline ActorId
    getDestination() const noexcept {
        return dest;
    }

    [[nodiscard]] inline ActorId
    getSource() const noexcept {
        return source;
    }
};

using pipe = Pipe;
 
} // namespace qb
#endif // QB_PROXYPIPE_H