pub fn gen_recover_async<'a, W: Write + BackToTheBuffer + 'a>(
        method: &'a RecoverAsync,
    ) -> impl SerializeFn<W> + 'a {
        move |mut input| {
            let mut flags = AMQPFlags::default();
            flags.add_flag("requeue".to_string(), method.requeue);
            input = gen_id(100)(input)?;
            input = gen_flags(&flags)(input)?;
            Ok(input)
        }
    }
/// Serialize recover-async (Generated)
Serialize recover-async (Generated)
Serialize recover - async ( Generated )
pub fn gen_recover_async<'a, W: Write + BackToTheBuffer + 'a>(
        method: &'a RecoverAsync,
    ) -> impl SerializeFn<W> + 'a {
        move |mut input| {
            let mut flags = AMQPFlags::default();
            flags.add_flag("requeue".to_string(), method.requeue);
            input = gen_id(100)(input)?;
            input = gen_flags(&flags)(input)?;
            Ok(input)
        }
    }
pub fn gen_recover_async < ' a , W : Write + BackToTheBuffer + ' a > ( method : & ' a RecoverAsync , ) -> impl SerializeFn < W > + ' a { move | mut input | { let mut flags = AMQPFlags :: default ( ) ; flags . add_flag ( " " . to_string ( ) , method . requeue ) ; input = gen_id ( 100 ) ( input ) ? ; input = gen_flags ( & flags ) ( input ) ? ; Ok ( input ) } }
Serialize recover-async (Generated)
Serialize recover - async ( Generated )
method
&'a RecoverAsync