Trait OutboundConnectionUpgrade

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

    // Required method
    fn upgrade_outbound(self, socket: T, info: Self::Info) -> Self::Future;
}

Possible upgrade on an outbound connection

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_outbound(self, socket: T, 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

impl<C> OutboundConnectionUpgrade<C> for libp2p::plaintext::Config

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

type Output = (PeerId, Output<C>)

type Error = Error

type Future = Pin<Box<dyn Future<Output = Result<<Config as OutboundConnectionUpgrade<C>>::Output, <Config as OutboundConnectionUpgrade<C>>::Error>> + Send>>

impl<C> OutboundConnectionUpgrade<C> for libp2p::tls::Config

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

type Output = (PeerId, TlsStream<C>)

type Error = UpgradeError

type Future = Pin<Box<dyn Future<Output = Result<<Config as OutboundConnectionUpgrade<C>>::Output, <Config as OutboundConnectionUpgrade<C>>::Error>> + Send>>

impl<C> OutboundConnectionUpgrade<C> for libp2p::yamux::Config

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

type Output = Muxer<C>

type Error = Error

type Future = Ready<Result<<Config as OutboundConnectionUpgrade<C>>::Output, <Config as OutboundConnectionUpgrade<C>>::Error>>

impl<C, A, B, TA, TB, EA, EB> OutboundConnectionUpgrade<C> for SelectUpgrade<A, B>

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

type Output = Either<TA, TB>

type Error = Either<EA, EB>

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

impl<T> OutboundConnectionUpgrade<T> for libp2p::noise::Config

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

type Output = (PeerId, Output<T>)

type Error = Error

type Future = Pin<Box<dyn Future<Output = Result<<Config as OutboundConnectionUpgrade<T>>::Output, <Config as OutboundConnectionUpgrade<T>>::Error>> + Send>>