/// Decorates the given future with error mapping,
/// reset handling, and a standard timeout.
Decorates the given future with error mapping,
reset handling, and a standard timeout.
Decorates the given future with error mapping reset handling and a standard timeout .
pub(super) fn apply_standard_combinators<'a, F>(
        &'a self,
        future: F,
    ) -> impl Future<Output = ZxResult<F::Ok>> + 'a
    where
        F: TryFuture<Error = Error> + Unpin + Send + 'a,
        <F as TryFuture>::Ok: Send,
    {
        future
            .inspect_err(|e| fx_log_err!("apply_standard_combinators: {:?}", e))
            .map_err(|e| ZxStatus::from(ErrorAdapter(e)))
            .cancel_upon(self.ncp_did_reset.wait(), Err(ZxStatus::CANCELED))
            .on_timeout(Time::after(DEFAULT_TIMEOUT), ncp_cmd_timeout!(self))
    }
pub ( super ) fn apply_standard_combinators < ' a , F > ( & ' a self , future : F , ) -> impl Future < Output = ZxResult < F :: Ok > > + ' a where F : TryFuture < Error = Error > + Unpin + Send + ' a , < F as TryFuture > :: Ok : Send , { future . inspect_err ( | e | fx_log_err ! ( " " e ) ) . map_err ( | e | ZxStatus :: from ( ErrorAdapter ( e ) ) ) . cancel_upon ( self . ncp_did_reset . wait ( ) , Err ( ZxStatus :: CANCELED ) ) . on_timeout ( Time :: after ( DEFAULT_TIMEOUT ) , ncp_cmd_timeout ! ( self ) ) }
Decorates the given future with error mapping,
reset handling, and a standard timeout.
Decorates the given future with error mapping reset handling and a standard timeout .
&'a self
future
F