Kagome
Polkadot Runtime Engine in C++17
kagome::network::RequestResponseProtocol< Request, Response, ReadWriter > Member List

This is the complete list of members for kagome::network::RequestResponseProtocol< Request, Response, ReadWriter >, including all inherited members.

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) overridekagome::network::RequestResponseProtocol< Request, Response, ReadWriter >inlineprivatevirtual
onIncomingStream(std::shared_ptr< Stream > stream) overridekagome::network::RequestResponseProtocol< Request, Response, ReadWriter >inlineprivatevirtual
onRxRequest(RequestType request, std::shared_ptr< Stream > stream)=0kagome::network::RequestResponseProtocol< Request, Response, ReadWriter >protectedpure virtual
onTxRequest(RequestType const &request)=0kagome::network::RequestResponseProtocol< Request, Response, ReadWriter >protectedpure virtual
operator=(ProtocolBase &&) noexcept=deletekagome::network::ProtocolBase
operator=(ProtocolBase const &)=deletekagome::network::ProtocolBase
protocol_kagome::network::RequestResponseProtocol< Request, Response, ReadWriter >private
ProtocolBase()=defaultkagome::network::ProtocolBase
ProtocolBase(ProtocolBase &&) noexcept=deletekagome::network::ProtocolBase
ProtocolBase(const ProtocolBase &)=deletekagome::network::ProtocolBase
ProtocolBaseImpl classkagome::network::RequestResponseProtocol< Request, Response, ReadWriter >friend
protocolName() const overridekagome::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 typedefkagome::network::RequestResponseProtocol< Request, Response, ReadWriter >
RequestResponseProtocol(libp2p::Host &host, Protocol const &protocol, ProtocolName const &name)kagome::network::RequestResponseProtocol< Request, Response, ReadWriter >inline
RequestType typedefkagome::network::RequestResponseProtocol< Request, Response, ReadWriter >
ResponseType typedefkagome::network::RequestResponseProtocol< Request, Response, ReadWriter >
start() overridekagome::network::RequestResponseProtocol< Request, Response, ReadWriter >inlinevirtual
stop() overridekagome::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()=defaultkagome::network::ProtocolBasevirtual
~RequestResponseProtocol()kagome::network::RequestResponseProtocol< Request, Response, ReadWriter >inlinevirtual