base() | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprotected |
base_ | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | private |
doRequest(const PeerId &peer_id, RequestType request, std::function< void(outcome::result< ResponseType >)> &&response_handler) | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inline |
newOutgoingStream(const PeerInfo &peer_info, std::function< void(outcome::result< std::shared_ptr< Stream >>)> &&cb) override | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprivatevirtual |
onIncomingStream(std::shared_ptr< Stream > stream) override | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprivatevirtual |
onRxRequest(RequestType request, std::shared_ptr< Stream > stream)=0 | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | protectedpure virtual |
onTxRequest(RequestType const &request)=0 | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | protectedpure virtual |
operator=(ProtocolBase &&) noexcept=delete | kagome::network::ProtocolBase | |
operator=(ProtocolBase const &)=delete | kagome::network::ProtocolBase | |
protocol_ | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | private |
ProtocolBase()=default | kagome::network::ProtocolBase | |
ProtocolBase(ProtocolBase &&) noexcept=delete | kagome::network::ProtocolBase | |
ProtocolBase(const ProtocolBase &)=delete | kagome::network::ProtocolBase | |
ProtocolBaseImpl class | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | friend |
protocolName() const override | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlinevirtual |
read(std::shared_ptr< Stream > stream, std::function< void(outcome::result< M >, std::shared_ptr< Stream >)> &&cb) | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprivate |
readRequest(std::shared_ptr< Stream > stream) | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprivate |
readResponse(std::shared_ptr< Stream > stream, std::function< void(outcome::result< ResponseType >)> &&cb) | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprivate |
ReadWriterType typedef | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | |
RequestResponseProtocol(libp2p::Host &host, Protocol const &protocol, ProtocolName const &name) | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inline |
RequestType typedef | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | |
ResponseType typedef | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | |
start() override | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlinevirtual |
stop() override | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlinevirtual |
write(std::shared_ptr< Stream > stream, M msg, std::function< void(outcome::result< void >, std::shared_ptr< Stream >)> &&cb) | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprivate |
writeRequest(std::shared_ptr< Stream > stream, RequestType request, std::function< void(outcome::result< ResponseType >)> &&cb) | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprivate |
writeResponse(std::shared_ptr< Stream > stream, ResponseType response) | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlineprivate |
~ProtocolBase()=default | kagome::network::ProtocolBase | virtual |
~RequestResponseProtocol() | kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > | inlinevirtual |