fifo_receiver.h

#ifndef FIFO_RECEIVER_H
#define FIFO_RECEIVER_H
 
#include <sys/stat.h>
#include <string>
#include <array>
#include "./communicator.h"
 
namespace AsyncBsdSocketLib
{
    class FifoReceiver : public Communicator
    {
    private:
        const std::string mPathname;
 
    public:
        FifoReceiver() = delete;

        FifoReceiver(std::string pathname);
 
        int Connection() const noexcept override;
 
        bool TrySetup() noexcept override;

        template <std::size_t N>
        ssize_t Receive(std::array<uint8_t, N> &buffer) const noexcept
        {
            ssize_t _result = read(FileDescriptor, buffer.data(), N);
 
            return _result;
        }
    };
}
 
#endif