macOS/iOS切换网络时reqwest Response挂起问题求助

我搭建了一个概念验证场景：当用FuturesAsyncReadCompatExt把reqwest::async_impl::Response包装成tokio_io::AsyncRead后，在蜂窝/WiFi/有线网络间切换时，tokio::io::copy会永久挂起。该问题在macOS和iOS平台可复现。

核心疑问 #

1. 如何让response_to_file在网络切换后返回错误，而非挂起？
2. 如果无法直接修复现有代码，该如何实现出错时能干净退出的「网络资源流式复制到临时文件」逻辑？

解决方案 #

方案1：移除冗余兼容性包装，使用原生Tokio异步流 #

问题根源在于跨生态的compat()适配层可能丢失了底层流的错误通知。reqwest的字节流转异步读取后，已经原生支持Tokio的AsyncRead，无需额外兼容包装：

async fn response_to_file(response: Response, path: PathBuf) -> Result<(), ApiError> {
    let mut download = response.bytes_stream()
        .map_err(|e| futures::io::Error::new(futures::io::ErrorKind::Other, e))
        .into_async_read();

    // 保留进度包装（按需使用）
    let mut download = ProgressReadAdapter::new(download);

    let temp_file = tokio::task::spawn_blocking(NamedTempFile::new)
        .await
        .wrap_api_err()?
        .wrap_api_err()?;

    let mut outfile = tokio::fs::File::create(temp_file.path())
        .await
        .wrap_api_err()?;

    tokio::io::copy(&mut download, &mut outfile)
        .await
        .wrap_api_err()?;

    outfile.flush().await.wrap_api_err()?;

    let _persisted_file: File = tokio::task::spawn_blocking(move || temp_file.persist(path))
        .await
        .wrap_api_err()?
        .wrap_api_err()?;

    Ok(())
}

关键改动：删除download.compat()调用，让流直接使用Tokio原生异步IO逻辑，网络切换时能正确触发底层错误。

方案2：给复制操作添加超时兜底 #

如果必须保留原有兼容性包装，可以用超时机制强制终止挂起的复制操作：

// 替换原tokio::io::copy调用，添加10秒超时
tokio::time::timeout(Duration::from_secs(10), tokio::io::copy(&mut download, &mut outfile))
    .await
    .map_err(|_| ApiError::new("Download timed out after network switch"))?
    .wrap_api_err()?;

注意：超时时间需要根据业务场景调整，避免误杀正常的慢传输。

方案3：手动分块读取，监控每一步状态 #

放弃使用tokio::io::copy，手动循环读取流分块，给每一次读取操作单独设置超时，精准捕获网络中断：

async fn response_to_file(response: Response, path: PathBuf) -> Result<(), ApiError> {
    let mut download = response.bytes_stream()
        .map_err(|e| futures::io::Error::new(futures::io::ErrorKind::Other, e))
        .into_async_read();

    let mut download = ProgressReadAdapter::new(download);

    let temp_file = tokio::task::spawn_blocking(NamedTempFile::new)
        .await
        .wrap_api_err()?
        .wrap_api_err()?;

    let mut outfile = tokio::fs::File::create(temp_file.path())
        .await
        .wrap_api_err()?;

    let mut buf = [0u8; 4096];
    loop {
        // 给单次读取设置5秒超时
        let n = tokio::time::timeout(Duration::from_secs(5), download.read(&mut buf))
            .await
            .map_err(|_| ApiError::new("Read timed out"))?
            .wrap_api_err()?;

        if n == 0 {
            break; // 流读取完成
        }

        outfile.write_all(&buf[..n])
            .await
            .wrap_api_err()?;
    }

    outfile.flush().await.wrap_api_err()?;

    let _persisted_file: File = tokio::task::spawn_blocking(move || temp_file.persist(path))
        .await
        .wrap_api_err()?
        .wrap_api_err()?;

    Ok(())
}

这种方式能在网络切换后立刻触发超时错误，避免无限挂起，同时保留流式传输的优势。

补充说明 #

• 原代码中设置的tcp_keepalive和connect_timeout仅对连接建立阶段生效，无法处理连接后的网络切换场景。
• 若使用TLS加密传输，需要自定义TLS连接器配置心跳参数，确保TLS会话在网络切换后能检测到连接中断。

内容的提问来源于stack exchange，提问作者Erik Živković