pub trait InboundUpgrade<C>: UpgradeInfo {
    type Output;
    type Error;
    type Future: Future<Output = Result<Self::Output, Self::Error>>;

    // Required method
    fn upgrade_inbound(self, socket: C, info: Self::Info) -> Self::Future;
}
Expand description

Possible upgrade on an inbound connection or substream.

Required Associated Types§

source

type Output

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

source

type Error

Possible error during the handshake.

source

type Future: Future<Output = Result<Self::Output, Self::Error>>

Future that performs the handshake with the remote.

Required Methods§

source

fn upgrade_inbound(self, socket: C, info: 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.

The info is the identifier of the protocol, as produced by protocol_info.

Implementors§

source§

impl<C> InboundUpgrade<C> for DeniedUpgrade

source§

impl<C> InboundUpgrade<C> for KademliaProtocolConfigwhere C: AsyncRead + AsyncWrite + Unpin,

source§

impl<C> InboundUpgrade<C> for MplexConfigwhere C: AsyncRead + AsyncWrite + Unpin,

source§

impl<C> InboundUpgrade<C> for YamuxConfigwhere C: AsyncRead + AsyncWrite + Send + Unpin + 'static,

source§

impl<C> InboundUpgrade<C> for YamuxLocalConfigwhere C: AsyncRead + AsyncWrite + Unpin + 'static,

source§

impl<C, A, B, TA, TB, EA, EB> InboundUpgrade<C> for EitherUpgrade<A, B>where A: InboundUpgrade<C, Output = TA, Error = EA>, B: InboundUpgrade<C, Output = TB, Error = EB>,

§

type Output = EitherOutput<TA, TB>

§

type Error = EitherError<EA, EB>

§

type Future = EitherFuture2<<A as InboundUpgrade<C>>::Future, <B as InboundUpgrade<C>>::Future>

source§

impl<C, A, B, TA, TB, EA, EB> InboundUpgrade<C> for SelectUpgrade<A, B>where A: InboundUpgrade<C, Output = TA, Error = EA>, B: InboundUpgrade<C, Output = TB, Error = EB>,

§

type Output = EitherOutput<TA, TB>

§

type Error = EitherError<EA, EB>

§

type Future = EitherFuture2<<A as InboundUpgrade<C>>::Future, <B as InboundUpgrade<C>>::Future>

source§

impl<C, F, O, A, E> InboundUpgrade<C> for SimpleProtocol<F>where C: AsyncRead + AsyncWrite, F: Fn(C) -> O, O: Future<Output = Result<A, E>>,

§

type Output = A

§

type Error = E

§

type Future = O

source§

impl<C, P> InboundUpgrade<C> for PendingUpgrade<P>where P: ProtocolName + Clone,

source§

impl<C, P> InboundUpgrade<C> for ReadyUpgrade<P>where P: ProtocolName + Clone,

source§

impl<C, P, F, Fut, Err, Out> InboundUpgrade<C> for FromFnUpgrade<P, F>where P: ProtocolName + Clone, F: FnOnce(C, Endpoint) -> Fut, Fut: Future<Output = Result<Out, Err>>,

§

type Output = Out

§

type Error = Err

§

type Future = Fut

source§

impl<C, T> InboundUpgrade<C> for OptionalUpgrade<T>where T: InboundUpgrade<C>,

§

type Output = <T as InboundUpgrade<C>>::Output

§

type Error = <T as InboundUpgrade<C>>::Error

§

type Future = <T as InboundUpgrade<C>>::Future

source§

impl<C, U, F> InboundUpgrade<C> for MapOutboundUpgrade<U, F>where U: InboundUpgrade<C>,

§

type Output = <U as InboundUpgrade<C>>::Output

§

type Error = <U as InboundUpgrade<C>>::Error

§

type Future = <U as InboundUpgrade<C>>::Future

source§

impl<C, U, F> InboundUpgrade<C> for MapOutboundUpgradeErr<U, F>where U: InboundUpgrade<C>,

§

type Output = <U as InboundUpgrade<C>>::Output

§

type Error = <U as InboundUpgrade<C>>::Error

§

type Future = <U as InboundUpgrade<C>>::Future

source§

impl<C, U, F, T> InboundUpgrade<C> for MapInboundUpgrade<U, F>where U: InboundUpgrade<C>, F: FnOnce(<U as InboundUpgrade<C>>::Output) -> T,

§

type Output = T

§

type Error = <U as InboundUpgrade<C>>::Error

§

type Future = MapFuture<<U as InboundUpgrade<C>>::Future, F>

source§

impl<C, U, F, T> InboundUpgrade<C> for MapInboundUpgradeErr<U, F>where U: InboundUpgrade<C>, F: FnOnce(<U as InboundUpgrade<C>>::Error) -> T,

§

type Output = <U as InboundUpgrade<C>>::Output

§

type Error = T

§

type Future = MapErrFuture<<U as InboundUpgrade<C>>::Future, F>

source§

impl<T> InboundUpgrade<Negotiated<SubstreamBox>> for SendWrapper<T>where T: InboundUpgradeSend,

source§

impl<T, C> InboundUpgrade<T> for NoiseConfig<IK, C, ()>where NoiseConfig<IK, C, ()>: UpgradeInfo, T: AsyncRead + AsyncWrite + Unpin + Send + 'static, C: Protocol<C> + AsRef<[u8]> + Zeroize + Clone + Send + 'static,

Implements the responder part of the IK handshake pattern.

IK is a single round-trip (2 messages) handshake.

In the IK handshake, the initiator is expected to know the responder’s identity already, which is why the responder does not send it in the second message.

initiator -{id}-> responder
initiator <-{id}- responder
source§

impl<T, C> InboundUpgrade<T> for NoiseConfig<IX, C, ()>where NoiseConfig<IX, C, ()>: UpgradeInfo, T: AsyncRead + AsyncWrite + Unpin + Send + 'static, C: Protocol<C> + AsRef<[u8]> + Zeroize + Clone + Send + 'static,

Implements the responder part of the IX noise handshake pattern.

IX is a single round-trip (2 messages) handshake in which each party sends their identity over to the other party.

initiator -{id}-> responder
initiator <-{id}- responder
source§

impl<T, C> InboundUpgrade<T> for NoiseConfig<XX, C, ()>where NoiseConfig<XX, C, ()>: UpgradeInfo, T: AsyncRead + AsyncWrite + Unpin + Send + 'static, C: Protocol<C> + AsRef<[u8]> + Zeroize + Clone + Send + 'static,

Implements the responder part of the XX noise handshake pattern.

XX is a 1.5 round-trip (3 messages) handshake. The first message in a noise handshake is unencrypted. In the XX handshake pattern, that message is empty and thus does not leak any information. The identities are then exchanged in the second and third message.

initiator --{}--> responder
initiator <-{id}- responder
initiator -{id}-> responder
source§

impl<T, P, C, R> InboundUpgrade<T> for NoiseAuthenticated<P, C, R>where NoiseConfig<P, C, R>: UpgradeInfo + InboundUpgrade<T, Output = (RemoteIdentity<C>, NoiseOutput<T>), Error = NoiseError> + 'static, <NoiseConfig<P, C, R> as InboundUpgrade<T>>::Future: Send, T: AsyncRead + AsyncWrite + Send + 'static, C: Protocol<C> + AsRef<[u8]> + Zeroize + Send + 'static,

source§

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