Struct libp2p::request_response::handler::ResponseProtocol

pub struct ResponseProtocol<TCodec> where
    TCodec: RequestResponseCodec,  { /* fields omitted */ }

Response substream upgrade protocol.

Receives a request and sends a response.

Trait Implementations

impl<TCodec> Debug for ResponseProtocol<TCodec> where
    TCodec: Debug + RequestResponseCodec,
    <TCodec as RequestResponseCodec>::Protocol: Debug,
    <TCodec as RequestResponseCodec>::Request: Debug,
    <TCodec as RequestResponseCodec>::Response: Debug, 

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

Formats the value using the given formatter.

impl<TCodec> InboundUpgrade<Negotiated<SubstreamRef<Arc<StreamMuxerBox>>>> for ResponseProtocol<TCodec> where
    TCodec: RequestResponseCodec + Send + 'static, 

type Output = bool

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<<ResponseProtocol<TCodec> as InboundUpgrade<Negotiated<SubstreamRef<Arc<StreamMuxerBox>>>>>::Output, <ResponseProtocol<TCodec> as InboundUpgrade<Negotiated<SubstreamRef<Arc<StreamMuxerBox>>>>>::Error>> + 'static + Send, Global>>

Future that performs the handshake with the remote.

pub fn upgrade_inbound(
    self,
    io: Negotiated<SubstreamRef<Arc<StreamMuxerBox>>>,
    protocol: <ResponseProtocol<TCodec> as UpgradeInfo>::Info
) -> <ResponseProtocol<TCodec> as InboundUpgrade<Negotiated<SubstreamRef<Arc<StreamMuxerBox>>>>>::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 ResponseProtocol<TCodec> where
    TCodec: RequestResponseCodec, 

type Info = <TCodec as RequestResponseCodec>::Protocol

Opaque type representing a negotiable protocol.

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

Iterator returned by protocol_info.

pub fn protocol_info(
    &self
) -> <ResponseProtocol<TCodec> as UpgradeInfo>::InfoIter

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