Trait tet_libp2p_core::upgrade::OutboundUpgrade[−][src]

pub trait OutboundUpgrade<C>: UpgradeInfo {
    type Output;
    type Error;
    type Future: Future<Output = Result<Self::Output, Self::Error>>;
    fn upgrade_outbound(self, socket: C, info: Self::Info) -> Self::Future;
}

Possible upgrade on an outbound connection or substream.

Associated Types

type Output[src]

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

type Error[src]

Possible error during the handshake.

type Future: Future<Output = Result<Self::Output, Self::Error>>[src]

Future that performs the handshake with the remote.

Loading content...

Required methods

fn upgrade_outbound(self, socket: C, info: Self::Info) -> Self::Future[src]

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.

Loading content...

Implementors

impl<C> OutboundUpgrade<C> for DeniedUpgrade[src]

type Output = Void

type Error = Void

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

impl<C, A, B, TA, TB, EA, EB> OutboundUpgrade<C> for EitherUpgrade<A, B> where
    A: OutboundUpgrade<C, Output = TA, Error = EA>,
    B: OutboundUpgrade<C, Output = TB, Error = EB>, [src]

type Output = EitherOutput<TA, TB>

type Error = EitherError<EA, EB>

type Future = EitherFuture2<A::Future, B::Future>

impl<C, A, B, TA, TB, EA, EB> OutboundUpgrade<C> for SelectUpgrade<A, B> where
    A: OutboundUpgrade<C, Output = TA, Error = EA>,
    B: OutboundUpgrade<C, Output = TB, Error = EB>, [src]

type Output = EitherOutput<TA, TB>

type Error = EitherError<EA, EB>

type Future = EitherFuture2<A::Future, B::Future>

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

type Output = Out

type Error = Err

type Future = Fut

impl<C, T> OutboundUpgrade<C> for OptionalUpgrade<T> where
    T: OutboundUpgrade<C>, [src]

type Output = T::Output

type Error = T::Error

type Future = T::Future

impl<C, U, F> OutboundUpgrade<C> for MapInboundUpgrade<U, F> where
    U: OutboundUpgrade<C>, [src]

type Output = U::Output

type Error = U::Error

type Future = U::Future

impl<C, U, F> OutboundUpgrade<C> for MapInboundUpgradeErr<U, F> where
    U: OutboundUpgrade<C>, [src]

type Output = U::Output

type Error = U::Error

type Future = U::Future

impl<C, U, F, T> OutboundUpgrade<C> for MapOutboundUpgrade<U, F> where
    U: OutboundUpgrade<C>,
    F: FnOnce(U::Output) -> T, [src]

type Output = T

type Error = U::Error

type Future = MapFuture<U::Future, F>

impl<C, U, F, T> OutboundUpgrade<C> for MapOutboundUpgradeErr<U, F> where
    U: OutboundUpgrade<C>,
    F: FnOnce(U::Error) -> T, [src]

type Output = U::Output

type Error = T

type Future = MapErrFuture<U::Future, F>

Loading content...