DisruptorConsumer.h

Go to the documentation of this file.

 
#pragma once
#include "DisruptorElement.h"
#include <functional>
 
namespace catapult { namespace disruptor {
 
    template<typename TInput>
    using DisruptorConsumerT = std::function<ConsumerResult (TInput&)>;
 
    using DisruptorConsumer = DisruptorConsumerT<ConsumerInput>;
 
    using ConstDisruptorConsumer = DisruptorConsumerT<const ConsumerInput>;
 
    using BlockConsumer = DisruptorConsumerT<BlockElements>;
 
    using ConstBlockConsumer = DisruptorConsumerT<const BlockElements>;
 
    using TransactionConsumer = DisruptorConsumerT<TransactionElements>;
 
    using ConstTransactionConsumer = DisruptorConsumerT<const TransactionElements>;
 
    std::vector<DisruptorConsumer> DisruptorConsumersFromBlockConsumers(const std::vector<BlockConsumer>& blockConsumers);
 
    std::vector<DisruptorConsumer> DisruptorConsumersFromTransactionConsumers(
            const std::vector<TransactionConsumer>& transactionConsumers);
}}