web-streams 0.1.3

WASM bindings for the Streams API
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
41
42

use wasm_bindgen::prelude::*;
use wasm_bindgen_futures::JsFuture;
use web_sys::{WritableStream, WritableStreamDefaultWriter};

use crate::{Error, PromiseExt};

// Wrapper around WritableStream
pub struct Writer {
	inner: WritableStreamDefaultWriter,
}

impl Writer {
	pub fn new(stream: &WritableStream) -> Result<Self, Error> {
		let inner = stream.get_writer()?.unchecked_into();
		Ok(Self { inner })
	}

	pub async fn write(&mut self, v: &JsValue) -> Result<(), Error> {
		JsFuture::from(self.inner.write_with_chunk(v)).await?;
		Ok(())
	}

	pub fn close(&mut self) {
		self.inner.close().ignore();
	}

	pub fn abort(&mut self, reason: &str) {
		let str = JsValue::from_str(reason);
		self.inner.abort_with_reason(&str).ignore();
	}

	pub async fn closed(&self) -> Result<(), Error> {
		JsFuture::from(self.inner.closed()).await?;
		Ok(())
	}
}

impl Drop for Writer {
	fn drop(&mut self) {
		self.inner.release_lock();
	}
}