how to merge multiple streams from different container logs into one stream?

[ManuelSopenaBallesteros]

Dear kube-rs team,
I have a method like this

    let mut logs_stream = pods_api
        .log_stream(
            cfs_session_pod.metadata.name.as_ref().unwrap(),
            &kube::api::LogParams {
                follow: true,
                container: Some(container_1.name.clone()),
                ..kube::api::LogParams::default()
            },
        )
        .await;

    while let Some(line) = logs_stream.try_next().await.unwrap() {
        println!("{}", line);
    }

    let mut logs_stream = pods_api
        .log_stream(
            cfs_session_pod.metadata.name.as_ref().unwrap(),
            &kube::api::LogParams {
                follow: true,
                container: Some(container_2.name.clone()),
                ..kube::api::LogParams::default()
            },
        )
        .await;
        .map_err(|e| Error::K8sError(format!("{e}")))?
        .lines();


    while let Some(line) = logs_stream.try_next().await.unwrap() {
        println!("{}", line);
    }

And I would like to achieve something like below:

    let mut logs_stream_1 = pods_api
        .log_stream(
            cfs_session_pod.metadata.name.as_ref().unwrap(),
            &kube::api::LogParams {
                follow: true,
                container: Some(container_1.name.clone()),
                ..kube::api::LogParams::default()
            },
        )
        .await;

    let mut logs_stream_2 = pods_api
        .log_stream(
            cfs_session_pod.metadata.name.as_ref().unwrap(),
            &kube::api::LogParams {
                follow: true,
                container: Some(container_2.name.clone()),
                ..kube::api::LogParams::default()
            },
        )
        .await;
        .map_err(|e| Error::K8sError(format!("{e}")))?
        .lines();

    let merge_logs_stream = logs_stream_1.merge(logs_stream_2);

    while let Some(line) = merge_logs_stream.try_next().await.unwrap() {
        println!("{}", line);
    }

I would like to ask if it is possible to merge both streams into a single one

thank you

[clux]

you could try packing each stream source in an enum element with select_all to combine the streams.

see for instance the multi watcher example. then you can match on the source (via the ad-hoc enum) in the while loop.

EDIT: if it's all log lines it's all the same type presumably, so you might not even need the enum.