pub async fn list_kf_topics<O>(
    out: std::sync::Arc<O>,
    mut client: KfClient<String>,
    output_type: OutputType,
) -> Result<(), CliError>
where
    O: Terminal,
{
    let topics = client.topic_metadata(None).await?;
    let wrapper_topics: Vec<KfTopicMetadata> = topics
        .into_iter()
        .map(|t| KfTopicMetadata::new(t))
        .collect();

    out.describe_objects(&wrapper_topics, output_type)
}
// Retrieve and print topics in desired format
Retrieve and print topics in desired format
Retrieve and print topics in desired format
pub async fn list_kf_topics<O>(
    out: std::sync::Arc<O>,
    mut client: KfClient<String>,
    output_type: OutputType,
) -> Result<(), CliError>
where
    O: Terminal,
{
    let topics = client.topic_metadata(None).await?;
    let wrapper_topics: Vec<KfTopicMetadata> = topics
        .into_iter()
        .map(|t| KfTopicMetadata::new(t))
        .collect();
    out.describe_objects(&wrapper_topics, output_type)
}
pub async fn list_kf_topics < O > ( out : std :: sync :: Arc < O > , mut client : KfClient < String > , output_type : OutputType , ) -> Result < ( ) , CliError > where O : Terminal , { let topics = client . topic_metadata ( None ) . await ? ; let wrapper_topics : Vec < KfTopicMetadata > = topics . into_iter ( ) . map ( | t | KfTopicMetadata :: new ( t ) ) . collect ( ) ; out . describe_objects ( & wrapper_topics , output_type ) }
Retrieve and print topics in desired format
Retrieve and print topics in desired format
out
std::sync::Arc<O>
client
KfClient<String>
output_type
OutputType
out
std::sync::Arc<O>
client
KfClient<String>
output_type
OutputType