SPSCChannel.hpp

// SPDX-FileCopyrightText: 2025 Vincent Leroy
// SPDX-License-Identifier: MIT
//
// This file is part of dfx.
//
// Licensed under the MIT License. See the LICENSE file in the project root
// for full license information.
 
#pragma once
 
// Porject includes
#include "../details/SyncQueue.hpp"
#include "Channel.hpp"
 
namespace dfx::Core
{
class SPSCChannel : public Channel
{
public:
    using Channel::Channel;
 
public:
    bool pushMessage(MessagePtr msg) override;

    bool hasPendingMessage() const override;

    std::size_t pendingMessageCount() const override;

    std::optional<MessagePtr> pop() override;
 
private:
    details::SyncQueue<MessagePtr, true, 64> _queue;
};
} // namespace dfx::Core