airio_core::upgrade

Trait Upgrade

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

    // Required methods
    fn upgrade_inbound(self, stream: S, info: Self::Info) -> Self::Future;
    fn upgrade_outbound(self, stream: S, info: Self::Info) -> Self::Future;
}

Expand description

流升级

Required Associated Types§

type Output

type Error

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

Required Methods§

fn upgrade_inbound(self, stream: S, info: Self::Info) -> Self::Future

升级入站流

fn upgrade_outbound(self, stream: S, info: Self::Info) -> Self::Future

升级出站流

Implementations on Foreign Types§

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

type Output = Either<TA, TB>

type Error = Either<EA, EB>

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

fn upgrade_inbound(self, stream: C, info: Self::Info) -> Self::Future

fn upgrade_outbound(self, stream: C, info: Self::Info) -> Self::Future

Implementors§

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

type Output = Either<TA, TB>

type Error = Either<EA, EB>

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

impl<C, P> Upgrade<C> for PendingUpgrade<P>
where P: AsRef<str> + Clone,

type Output = Infallible

type Error = Infallible

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

impl<C, P> Upgrade<C> for ReadyUpgrade<P>
where P: AsRef<str> + Clone,

type Output = C

type Error = Infallible

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