6 #ifndef IROHA_PEER_COMMUNICATION_SERVICE_IMPL_HPP 7 #define IROHA_PEER_COMMUNICATION_SERVICE_IMPL_HPP 15 class VerifiedProposalCreator;
18 namespace synchronizer {
28 std::shared_ptr<OrderingGate> ordering_gate,
29 std::shared_ptr<synchronizer::Synchronizer> synchronizer,
30 std::shared_ptr<simulator::VerifiedProposalCreator> proposal_creator,
34 std::shared_ptr<shared_model::interface::TransactionBatch> batch)
37 rxcpp::observable<OrderingEvent> onProposal()
const override;
39 rxcpp::observable<simulator::VerifiedProposalCreatorEvent>
40 onVerifiedProposal()
const override;
42 rxcpp::observable<synchronizer::SynchronizationEvent> on_commit()
46 std::shared_ptr<OrderingGate> ordering_gate_;
47 std::shared_ptr<synchronizer::Synchronizer> synchronizer_;
48 std::shared_ptr<simulator::VerifiedProposalCreator> proposal_creator_;
54 #endif // IROHA_PEER_COMMUNICATION_SERVICE_IMPL_HPP Definition: peer_communication_service.hpp:27
Definition: peer_communication_service_impl.hpp:25
std::shared_ptr< spdlog::logger > Logger
Definition: logger.hpp:26
Definition: block_query.hpp:16
Logger log(const std::string &tag)
Definition: logger.cpp:48