xwebtransport-web-sys 0.2.0

An implementation of the xwebtransport that runs in the browser. Powered by wasm-bindgen and web-sys.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use crate::Error;

pub fn get_reader(
    readable_stream: web_sys::ReadableStream,
) -> web_sys::ReadableStreamDefaultReader {
    let reader: wasm_bindgen::JsValue = readable_stream.get_reader().into();
    reader.into()
}

pub fn get_writer(
    writable_stream: web_sys::WritableStream,
) -> web_sys::WritableStreamDefaultWriter {
    writable_stream.get_writer().unwrap()
}

pub async fn read(reader: &web_sys::ReadableStreamDefaultReader) -> Result<Option<Vec<u8>>, Error> {
    let fut = wasm_bindgen_futures::JsFuture::from(reader.read());
    let result = fut.await.map_err(Error)?;
    let result: crate::sys::ReadableStreamDefaultReaderValue = result.into();
    let value = result.value();

    let Some(js_buf) = value else {
        if result.is_done() {
            return Ok(None);
        }
        unreachable!("no value and we are also not done, this should be impossible");
    };

    Ok(Some(js_buf.to_vec()))
}

pub async fn write<T>(writer: &web_sys::WritableStreamDefaultWriter, buf: T) -> Result<(), Error>
where
    js_sys::Uint8Array: From<T>,
{
    let chunk = js_sys::Uint8Array::from(buf);
    let fut = wasm_bindgen_futures::JsFuture::from(writer.write_with_chunk(chunk.as_ref()));
    fut.await.map_err(Error)?;
    Ok(())
}