xwt-anchor 0.3.0

Anchor types for xwt. Useful to overcome foreign type implementation limitations.
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

//! Implementations related to endpoint accept operations.

use xwt_core::utils::maybe;

use crate::types::*;

impl<T> xwt_core::endpoint::Accept for Endpoint<T>
where
    T: xwt_core::endpoint::Accept + maybe::Send + maybe::Sync,
{
    type Accepting = Accepting<T::Accepting>;
    type Error = T::Error;

    async fn accept(&self) -> Result<Option<Self::Accepting>, Self::Error> {
        T::accept(&self.0).await.map(|e| e.map(Accepting))
    }
}

impl<T> xwt_core::endpoint::accept::Accepting for Accepting<T>
where
    T: xwt_core::endpoint::accept::Accepting,
{
    type Request = Request<T::Request>;
    type Error = T::Error;

    async fn wait_accept(self) -> Result<Self::Request, Self::Error> {
        T::wait_accept(self.0).await.map(Request)
    }
}

impl<T> xwt_core::endpoint::accept::Request for Request<T>
where
    T: xwt_core::endpoint::accept::Request,
{
    type Session = Session<T::Session>;
    type OkError = T::OkError;
    type CloseError = T::CloseError;

    async fn ok(self) -> Result<Self::Session, Self::OkError> {
        T::ok(self.0).await.map(Session)
    }

    async fn close(self, status: u16) -> Result<(), Self::CloseError> {
        T::close(self.0, status).await
    }
}