ChainedSocketReader.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/ionet/PacketHandlers.h"
#include "catapult/ionet/SocketOperationCode.h"
#include <functional>
#include <memory>
 
namespace catapult {
    namespace ionet {
        class PacketSocket;
        struct ReaderIdentity;
    }
}
 
namespace catapult { namespace net {
 
    class ChainedSocketReader {
    public:
        virtual ~ChainedSocketReader() = default;
 
    public:
        using CompletionHandler = consumer<ionet::SocketOperationCode>;
 
    public:
        virtual void start() = 0;
 
        virtual void stop() = 0;
    };
 
    std::shared_ptr<ChainedSocketReader> CreateChainedSocketReader(
            const std::shared_ptr<ionet::PacketSocket>& pPacketSocket,
            const ionet::ServerPacketHandlers& serverHandlers,
            const ionet::ReaderIdentity& identity);
 
    std::shared_ptr<ChainedSocketReader> CreateChainedSocketReader(
            const std::shared_ptr<ionet::PacketSocket>& pPacketSocket,
            const ionet::ServerPacketHandlers& serverHandlers,
            const ionet::ReaderIdentity& identity,
            const ChainedSocketReader::CompletionHandler& completionHandler);
}}