Struct libp2p_request_response::handler::ResponseProtocol

[+] Show declaration

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

[−] Expand description

Response substream upgrade protocol.

Receives a request and sends a response.

Trait Implementations

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

[+] Show hidden undocumented items

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

Formats the value using the given formatter.

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

[+] Show hidden undocumented items

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 = BoxFuture<'static, Result<Self::Output, Self::Error>>

Future that performs the handshake with the remote.

fn upgrade_inbound(
    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 ResponseProtocol<TCodec> where
    TCodec: RequestResponseCodec, [+]

[+] Show hidden undocumented items

type Info = TCodec::Protocol

Opaque type representing a negotiable protocol.

type InfoIter = IntoIter<[Self::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.