[bug] Connections aborted when multiple requests sending at once

[lazytiger]

Describe the bug
Under normal circumstances, there is no issue. However, when multiple asynchronous HTTPS requests are sent consecutively at the same time, almost all the requests encounter a "Connection abort" error. The requests show the "Connect" method instead of the original POST/GET methods.

To Reproduce
Steps to reproduce the behavior:

• Use an asynchronous HTTP client to send multiple HTTPS requests simultaneously.
• Disable reqable, and the application functions normally.
• Enable reqable, and most requests will fail.

Expected behavior
Whether Reqable is enabled or not does not affect asynchronous concurrent HTTP requests.

Screenshots

Information

• Platform: [e.g. android]
• OS: [e.g. any]
• Arch: [e.g. arm, x86-64]
• App Version: [e.g. 3.0.32]

[MegatronKing]

Hello, do you have any code example?

[lazytiger]

I don't know if this is related to the one-session limit in the community version. The test code is actually very simple; you need to send several requests asynchronously at the same time. The attachment contains a reproducible demo, which, once extracted, provides an APK file.

use crate::reqable;
use reqwest::Client;

pub fn test() -> anyhow::Result<()> {
    #[cfg(target_os = "android")]
    {
        use crate::OptionToResult;
        let app = bevy::android::ANDROID_APP.get().to_ok()?;
        let vm = unsafe { jni::JavaVM::from_raw(app.vm_as_ptr() as _)? };
        let mut env = vm.get_env()?;
        let context = unsafe { jni::objects::JObject::from_raw(app.activity_as_ptr() as _) };
        rustls_platform_verifier::android::init_with_env(&mut env, context)?;
    }
    tokio::runtime::Builder::new_multi_thread()
        .enable_all()
        .build()?
        .block_on(async {
            if let Err(err) = reqable::fun().await {
                eprintln!("fun() failed: {:?}", err);
            }
        });
    Ok(())
}

async fn fun() -> anyhow::Result<()> {
    let client = Client::new();

    let client1 = client.clone();
    let task1 = tokio::task::spawn(async move {
        if let Err(err) = get("https://www.baidu.com", &client1).await {
            eprintln!("get {} failed: {:?}", "https://www.baidu.com", err);
        }
    });
    let client2 = client.clone();
    let task2 = tokio::task::spawn(async move {
        if let Err(err) = get("https://www.apple.com", &client2).await {
            eprintln!("get {} failed: {:?}", "https://www.apple.com", err);
        }
    });
    let task3 = tokio::task::spawn(async move {
        if let Err(err) = get("https://www.microsoft.com", &client).await {
            eprintln!("get {} failed: {:?}", "https://www.microsoft.com", err);
        }
    });
    task1.await?;
    task2.await?;
    task3.await?;
    Ok(())
}

async fn get(url: &str, client: &Client) -> anyhow::Result<()> {
    let resp = client.get(url).send().await?;
    let body = resp.text().await?;
    println!("{}", body);
    Ok(())
}

app-release.zip