adam/leptos-use
1
0
Fork 0
mirror of https://github.com/adoyle0/leptos-use.git synced 2025-01-23 00:59:22 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

disabled webtransport for now

Browse source
This commit is contained in:
Maccesch 2024-01-30 00:02:14 +00:00
parent 7fe153e525
commit a677eaf877
3 changed files with 15 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
examples/use_webtransport/.cargo/config.toml Normal file
View file

@ -0,0 +1,2 @@
[build]
rustflags = ["--cfg=web_sys_unstable_apis", "--cfg=has_std"]

8
src/lib.rs
View file

@ -9,10 +9,10 @@ pub mod math;
pub mod storage;
pub mod utils;
#[cfg(web_sys_unstable_apis)]
mod use_webtransport;
#[cfg(web_sys_unstable_apis)]
pub use use_webtransport::*;
// #[cfg(web_sys_unstable_apis)]
// mod use_webtransport;
// #[cfg(web_sys_unstable_apis)]
// pub use use_webtransport::*;
mod is_err;
mod is_none;

14
src/use_webtransport.rs
View file

@ -424,7 +424,6 @@ impl Default for UseWebTransportOptions {
pub enum StreamState {
Open,
Closed,
ClosedWithError(WebTransportError),
}
#[async_trait(?Send)]
@ -600,9 +599,8 @@ macro_rules! impl_closable_stream {
async fn close_async(&self) -> Result<(), WebTransportError> {
let _ = JsFuture::from(self.writer.close()).await.map_err(|e| {
let error = WebTransportError::FailedToCloseStream(e);
self.set_state
.set(StreamState::ClosedWithError(error.clone()));
let error = WebTransportError::OnCloseWriter(e);
self.set_state.set(StreamState::Closed);
error
})?;
@ -749,13 +747,19 @@ fn create_bidir_stream(
/// Error enum for [`UseWebTransportOptions::on_error`]
#[derive(Debug, Clone, Error)]
pub enum WebTransportError {
/// The `WebTransport` is not connected yet. Call `open` first.
#[error("The `WebTransport` is not connected yet. Call `open` first.")]
NotConnected,
#[error("Failed to open stream: {0:?}")]
FailedToOpenStream(JsValue),
#[error("Failed to open writer: {0:?}")]
FailedToOpenWriter(JsValue),
#[error("Failed to open reader: {0:?}")]
FailedToOpenReader(JsValue),
#[error("Failed to read from stream: {0:?}")]
FailedToRead(JsValue),
#[error("Failed to close writer: {0:?}")]
OnCloseWriter(JsValue),
#[error("Failed to close reader: {0:?}")]
OnCloseReader(JsValue),
}