xwt-core 0.9.0

A common WebTransport interface for browser and native. Write once, run anywhere.
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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

//! Utilitites for the WebTransport streams.

use crate::stream;

/// A shortcut for the error type for a given [`stream::Read`] type.
pub type ReadErrorFor<T> = <T as stream::Read>::Error;

/// A shortcut for the error type for a given [`stream::Write`] type.
pub type WriteErrorFor<T> = <T as stream::Write>::Error;

/// A shortcut for the error type for a given [`stream::ReadChunk] type.
pub type ReadChunkErrorFor<T, Data> = <T as stream::ReadChunk<Data>>::Error;

/// A shortcut for the error type for a given [`stream::WriteChunk] type.
pub type WriteChunkErrorFor<T, Data> = <T as stream::WriteChunk<Data>>::Error;

/// A shortcut for the error type for a given [`stream::ReadAbort`] type.
pub type ReadAbortErrorFor<T> = <T as stream::ReadAbort>::Error;

/// A shortcut for the error type for a given [`stream::ReadAborted`] type.
pub type ReadAbortedErrorFor<T> = <T as stream::ReadAborted>::Error;

/// A shortcut for the error type for a given [`stream::WriteAbort`] type.
pub type WriteAbortErrorFor<T> = <T as stream::WriteAbort>::Error;

/// A shortcut for the error type for a given [`stream::WriteAborted`] type.
pub type WriteAbortedErrorFor<T> = <T as stream::WriteAborted>::Error;

/// A shortcut for the error type for a given [`stream::Finish`] type.
pub type FinishErrorFor<T> = <T as stream::Finish>::Error;

/// A shortcut for the error type for a given [`stream::Finished`] type.
pub type FinishedErrorFor<T> = <T as stream::Finished>::Error;

/// Extensions to the [`stream::ErrorAsErrorCode`] providing some convenience methods.
pub trait ErrorAsErrorCodeExt: stream::ErrorAsErrorCode {
    /// Check of the error code matches the given value.
    fn is_error_code(&self, expected_code: stream::ErrorCode) -> bool;

    /// Checks that the error code exists and is zero.
    fn is_closed(&self) -> bool;
}

// Check that this trait is dyn-safe.
impl dyn ErrorAsErrorCodeExt {}

impl<T> ErrorAsErrorCodeExt for T
where
    T: ?Sized + stream::ErrorAsErrorCode,
{
    fn is_error_code(&self, expected_error_code: stream::ErrorCode) -> bool {
        let Some(error_code) = self.as_error_code() else {
            return false;
        };

        error_code == expected_error_code
    }

    fn is_closed(&self) -> bool {
        self.is_error_code(0)
    }
}