在Rust中如何从js_sys::Object获取ReadableStreamByobReader并读取字符串？

1. 类型转换获取ReadableStreamByobReader #

你可以通过JsCast trait提供的dyn_into方法（或直接into转换，前提是底层类型匹配）将返回的Object转为强类型的ReadableStreamByobReader，同时要处理转换错误（避免直接unwrap）：

use wasm_bindgen::JsCast;
use web_sys::{ReadableStream, ReadableStreamByobReader, ReadableStreamGetReaderOptions, ReadableStreamReaderMode};

// 获取Blob对应的ReadableStream
let stream: ReadableStream = blob.stream();

// 配置BYOB模式的reader选项
let mut opt = ReadableStreamGetReaderOptions::new();
opt.mode(ReadableStreamReaderMode::Byob);

// 获取reader并转换为强类型实例
let reader_obj = stream.get_reader_with_options(&opt);
let byob_reader = reader_obj.dyn_into::<ReadableStreamByobReader>()?; // 用?传播错误，替代unwrap

2. 异步读取并转换为Rust String #

由于文件小于4KB，创建一个4KB的缓冲区即可。通过wasm_bindgen_futures将Promise转为Rust Future，异步读取后处理字节数据：

use wasm_bindgen_futures::JsFuture;
use web_sys::{ReadableStreamReadResult, Uint8Array};

async fn read_small_text_blob(blob: &web_sys::Blob) -> Result<String, wasm_bindgen::JsValue> {
    // 上面的类型转换代码省略，直接复用byob_reader
    
    // 创建4KB缓冲区（覆盖文件大小上限）
    let mut buffer = vec![0u8; 4096];
    let uint8_array = Uint8Array::new_with_length(buffer.len() as u32);

    // 调用read方法，将Promise转为Rust Future并等待结果
    let read_promise = byob_reader.read(&uint8_array);
    let read_result_js = JsFuture::from(read_promise).await?;
    
    // 转换为ReadableStreamReadResult类型
    let read_result: ReadableStreamReadResult = read_result_js.dyn_into()?;

    // 处理读取完成状态
    if read_result.done() {
        return Ok(String::new());
    }

    // 将读取到的Uint8Array复制到Rust缓冲区
    let value = read_result.value().dyn_into::<Uint8Array>()?;
    value.copy_to(&mut buffer);
    
    // 截取实际读取的字节长度，转换为UTF8字符串
    let bytes = &buffer[..value.length() as usize];
    let text = String::from_utf8(bytes.to_vec())?;

    Ok(text)
}

关键说明 #

• 缓冲区处理：BYOB模式要求主动提供可写入的缓冲区，这里用Uint8Array作为JS侧的缓冲区，再复制到Rust的Vec<u8>中
• 异步适配：JsFuture::from将JS Promise转为Rust可await的Future，实现跨环境异步调用
• 错误处理：全程用?传播JsValue和UTF8转换错误，避免panic

内容的提问来源于stack exchange，提问作者peterk