async fn pipe_to_router(src_router: Router, dest_router: Router, producer_id: ProducerId) {
        let options = PipeToRouterOptions::new(dest_router.clone());
        match src_router
            .pipe_producer_to_router(producer_id, options)
            .await
        {
            Ok(_) => {
                println!(
                    "producer {:?} piped to router: {:?}",
                    producer_id,
                    dest_router.id()
                );
            }
            Err(error) => {
                println!("error while pipe_to_router {:?}", error);
            }
        }
    }
///
/// This function is used to pipe specified producer's stream from source router to destination router.
///
This function is used to pipe specified producer's stream from source router to destination router.
This function is used to pipe specified producer ' s stream from source router to destination router .
async fn pipe_to_router(src_router: Router, dest_router: Router, producer_id: ProducerId) {
        let options = PipeToRouterOptions::new(dest_router.clone());
        match src_router
            .pipe_producer_to_router(producer_id, options)
            .await
        {
            Ok(_) => {
                println!(
                    "producer {:?} piped to router: {:?}",
                    producer_id,
                    dest_router.id()
                );
            }
            Err(error) => {
                println!("error while pipe_to_router {:?}", error);
            }
        }
    }
async fn pipe_to_router ( src_router : Router , dest_router : Router , producer_id : ProducerId ) { let options = PipeToRouterOptions :: new ( dest_router . clone ( ) ) ; match src_router . pipe_producer_to_router ( producer_id , options ) . await { Ok ( _ ) => { println ! ( " " producer_id dest_router id ( ) ) ; } Err ( error ) => { println ! ( " " error ) ; } } }
This function is used to pipe specified producer's stream from source router to destination router.
This function is used to pipe specified producer ' s stream from source router to destination router .
src_router
Router
dest_router
Router
producer_id
ProducerId
src_router
Router
dest_router
Router
producer_id
ProducerId