asio_stream.hpp

#pragma once
#include <boost/asio/ip/tcp.hpp>
#include <kj/async-io.h>
 
namespace vanetza
{
namespace rpc
{
 
class AsioStream : public kj::AsyncIoStream
{
public:
    AsioStream(boost::asio::ip::tcp::socket socket);
 
    void shutdownWrite() override;
    kj::Promise<void> write(const void* buffer, size_t size) override;
    kj::Promise<void> write(kj::ArrayPtr<const kj::ArrayPtr<const kj::byte>> pieces) override;
    kj::Promise<void> whenWriteDisconnected() override;
    kj::Promise<size_t> tryRead(void* buffer, size_t minBytes, size_t maxBytes) override;
 
private:
    boost::asio::ip::tcp::socket socket_;
};
 
} // namepsace rpc
} // namespace vanetza