log_stream returns an opaque type

[ManuelSopenaBallesteros]

Dear kube-rs community,

I have a trait like below:

use futures::{io::Lines, AsyncBufReadExt};

pub trait CfsTrait {
    type T: AsyncBufReadExt;

    fn get_logs_stream(
        &self,
        container_name: &str,
    ) -> impl std::future::Future<Output = Result<Lines<Self::T>, Error>> + Send;
}

And this struct implementation:

impl CfsTrait for Csm {
    type T = Cursor<Vec<u8>>;

    async fn get_logs_stream(
        &self,
    ) -> Result<Lines<Cursor<Vec<u8>>>, Error> {
    let api = //...

    let pod = //...

    Ok(api
        .log_stream(
            pod.metadata.name.as_ref().unwrap(),
            &kube::api::LogParams {
                follow: true,
                container: Some("my_container_name".to_string()),
                ..kube::api::LogParams::default()
            },
        )
        .await
        .map_err(|e| Error::K8sError(format!("{e}")))?
        .lines())
}

This is not working because the type log_stream returns is opaque.

error[E0308]: mismatched types
   --> src/common/kubernetes.rs:948:8
    |
948 |       Ok(api
    |  _____--_^
    | |     |
    | |     arguments to this enum variant are incorrect
949 | |         .log_stream(
950 | |             pod.metadata.name.as_ref().unwrap(),
951 | |             &kube::api::LogParams {
...   |
958 | |         .map_err(|e| Error::K8sError(format!("{e}")))?
959 | |         .lines())
    | |________________^ expected `Lines<Cursor<Vec<u8>>>`, found `Lines<impl AsyncBufRead>`
    |
   ::: /Users/masber/.cargo/registry/src/index.crates.io-6f17d22bba15001f/kube-client-0.87.2/src/api/subresource.rs:427:74
    |
427 |       pub async fn log_stream(&self, name: &str, lp: &LogParams) -> Result<impl AsyncBufRead> {
    |                                                                            ----------------- the found opaque type
    |
    = note: expected struct `futures::io::Lines<futures::io::Cursor<Vec<u8>>>`
               found struct `futures::io::Lines<impl futures::AsyncBufRead>`
help: the type constructed contains `futures::io::Lines<impl futures::AsyncBufRead>` due to the type of the argument passed
   --> src/common/kubernetes.rs:948:5
    |
948 |        Ok(api
    |   _____^  -
    |  |________|
949 | ||         .log_stream(
950 | ||             pod.metadata.name.as_ref().unwrap(),
951 | ||             &kube::api::LogParams {
...   ||
958 | ||         .map_err(|e| Error::K8sError(format!("{e}")))?
959 | ||         .lines())
    | ||________________-^
    | |_________________|
    |                   this argument influences the type of `Ok`
note: tuple variant defined here
   --> /Users/masber/.rustup/toolchains/stable-aarch64-apple-darwin/lib/rustlib/src/rust/library/core/src/result.rs:532:5
    |
532 |     Ok(#[stable(feature = "rust1", since = "1.0.0")] T),
    |     ^^

• Any idea of how to get around this issue?
• Should I be using a different function?

thank you very much