SocketReader.h

Go to the documentation of this file.

 
#pragma once
#include "PacketHandlers.h"
#include "ReaderIdentity.h"
#include "SocketOperationCode.h"
#include <memory>
 
namespace catapult {
    namespace ionet {
        class BatchPacketReader;
        class PacketIo;
    }
}
 
namespace catapult { namespace ionet {
 
    class SocketReader {
    public:
        using ReadCallback = consumer<SocketOperationCode>;
 
    public:
        virtual ~SocketReader() = default;
 
    public:
        virtual void read(const ReadCallback& callback) = 0;
    };
 
    std::unique_ptr<SocketReader> CreateSocketReader(
            const std::shared_ptr<BatchPacketReader>& pReader,
            const std::shared_ptr<PacketIo>& pWriter,
            const ServerPacketHandlers& handlers,
            const ReaderIdentity& identity);
}}