pub async fn start_default(self) -> Result<(), AmqpDispatcherError> {
        let dispatcher = Dispatcher::new(
            self.connection,
            fn_service(|_| Ready::<_, LinkError>::Ok(())),
            fn_service(|_| Ready::<_, LinkError>::Ok(())),
            self.remote_config.timeout_remote_secs().into(),
        );

        let keepalive = if self.keepalive.non_zero() {
            self.keepalive + Seconds(5)
        } else {
            Seconds::ZERO
        };

        IoDispatcher::new(self.io, self.codec, dispatcher)
            .keepalive_timeout(keepalive)
            .await
    }
/// Run client with default control messages handler.
///
/// Default handler closes connection on any control message.
Run client with default control messages handler.
Default handler closes connection on any control message.
Run client with default control messages handler . Default handler closes connection on any control message .
pub async fn start_default(self) -> Result<(), AmqpDispatcherError> {
        let dispatcher = Dispatcher::new(
            self.connection,
            fn_service(|_| Ready::<_, LinkError>::Ok(())),
            fn_service(|_| Ready::<_, LinkError>::Ok(())),
            self.remote_config.timeout_remote_secs().into(),
        );
        let keepalive = if self.keepalive.non_zero() {
            self.keepalive + Seconds(5)
        } else {
            Seconds::ZERO
        };
        IoDispatcher::new(self.io, self.codec, dispatcher)
            .keepalive_timeout(keepalive)
            .await
    }
pub async fn start_default ( self ) -> Result < ( ) , AmqpDispatcherError > { let dispatcher = Dispatcher :: new ( self . connection , fn_service ( | _ | Ready :: < _ , LinkError > :: Ok ( ( ) ) ) , fn_service ( | _ | Ready :: < _ , LinkError > :: Ok ( ( ) ) ) , self . remote_config . timeout_remote_secs ( ) . into ( ) , ) ; let keepalive = if self . keepalive . non_zero ( ) { self . keepalive + Seconds ( 5 ) } else { Seconds :: ZERO } ; IoDispatcher :: new ( self . io , self . codec , dispatcher ) . keepalive_timeout ( keepalive ) . await }
Run client with default control messages handler.
Run client with default control messages handler .
self
self