Struct libp2p_request_response::handler::RequestProtocol

pub struct RequestProtocol<TCodec>
where
    TCodec: Codec,
{ /* private fields */ }

Request substream upgrade protocol.

Sends a request and receives a response.

Trait Implementations

impl<TCodec> Debug for RequestProtocol<TCodec>

where TCodec: Codec,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<TCodec> OutboundUpgrade<Negotiated<SubstreamBox>> for RequestProtocol<TCodec>

where TCodec: Codec + Send + 'static,

type Output = <TCodec as Codec>::Response

Output after the upgrade has been successfully negotiated and the handshake performed.

type Error = Error

Possible error during the handshake.

type Future = Pin<Box<dyn Future<Output = Result<<RequestProtocol<TCodec> as OutboundUpgrade<Negotiated<SubstreamBox>>>::Output, <RequestProtocol<TCodec> as OutboundUpgrade<Negotiated<SubstreamBox>>>::Error>> + Send>>

Future that performs the handshake with the remote.

fn upgrade_outbound( self, io: NegotiatedSubstream, protocol: Self::Info, ) -> Self::Future

After we have determined that the remote supports one of the protocols we support, this method is called to start the handshake.

impl<TCodec> UpgradeInfo for RequestProtocol<TCodec>

where TCodec: Codec,

type Info = <TCodec as Codec>::Protocol

Opaque type representing a negotiable protocol.

type InfoIter = IntoIter<[<RequestProtocol<TCodec> as UpgradeInfo>::Info; 2]>

Iterator returned by protocol_info.

fn protocol_info(&self) -> Self::InfoIter

Returns the list of protocols that are supported. Used during the negotiation process.