ClientConnector.h

Go to the documentation of this file.

 
#pragma once
#include "ConnectionSettings.h"
#include "PeerConnectCode.h"
#include "catapult/functions.h"
#include <memory>
 
namespace catapult {
    namespace crypto { class KeyPair; }
    namespace ionet { class PacketSocket; }
    namespace thread { class IoThreadPool; }
}
 
namespace catapult { namespace net {
 
    class ClientConnector {
    public:
        using AcceptCallback = consumer<PeerConnectCode, const std::shared_ptr<ionet::PacketSocket>&, const Key&>;
 
    public:
        virtual ~ClientConnector() = default;
 
    public:
        virtual size_t numActiveConnections() const = 0;
 
    public:
        virtual void accept(const std::shared_ptr<ionet::PacketSocket>& pAcceptedSocket, const AcceptCallback& callback) = 0;
 
        virtual void shutdown() = 0;
    };
 
    std::shared_ptr<ClientConnector> CreateClientConnector(
            const std::shared_ptr<thread::IoThreadPool>& pPool,
            const crypto::KeyPair& keyPair,
            const ConnectionSettings& settings);
}}