Trait libp2p::InboundUpgrade

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;
}

Possible upgrade on an inbound connection or substream.

Required Associated Types

type Output

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

type Error

Possible error during the handshake.

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

Future that performs the handshake with the remote.

Required Methods

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.

Implementations on Foreign Types

impl<C, A, B, TA, TB, EA, EB> InboundUpgrade<C> for Either<A, B>

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

type Output = Either<TA, TB>

type Error = Either<EA, EB>

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

fn upgrade_inbound( self, sock: C, info: <Either<A, B> as UpgradeInfo>::Info ) -> <Either<A, B> as InboundUpgrade<C>>::Future

Implementors

impl<C> InboundUpgrade<C> for DeniedUpgrade

type Output = Void

type Error = Void

type Future = Pending<Result<<DeniedUpgrade as InboundUpgrade<C>>::Output, <DeniedUpgrade as InboundUpgrade<C>>::Error>>

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 = Either<TA, TB>

type Error = Either<EA, EB>

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

impl<C, P> InboundUpgrade<C> for PendingUpgrade<P>

where P: AsRef<str> + Clone,

type Output = Void

type Error = Void

type Future = Pending<Result<<PendingUpgrade<P> as InboundUpgrade<C>>::Output, <PendingUpgrade<P> as InboundUpgrade<C>>::Error>>

impl<C, P> InboundUpgrade<C> for ReadyUpgrade<P>

where P: AsRef<str> + Clone,

type Output = C

type Error = Void

type Future = Ready<Result<<ReadyUpgrade<P> as InboundUpgrade<C>>::Output, <ReadyUpgrade<P> as InboundUpgrade<C>>::Error>>

impl<T> InboundUpgrade<Stream> for SendWrapper<T>

where T: InboundUpgradeSend,

type Output = <T as InboundUpgradeSend>::Output

type Error = <T as InboundUpgradeSend>::Error

type Future = <T as InboundUpgradeSend>::Future

impl<TSocket> InboundUpgrade<TSocket> for FloodsubProtocol

where TSocket: AsyncRead + AsyncWrite + Send + Unpin + 'static,

type Output = FloodsubRpc

type Error = FloodsubError

type Future = Pin<Box<dyn Future<Output = Result<<FloodsubProtocol as InboundUpgrade<TSocket>>::Output, <FloodsubProtocol as InboundUpgrade<TSocket>>::Error>> + Send>>