xwt_core/session/
stream.rs

1#![allow(missing_docs)]
2
3use core::future::Future;
4
5use crate::utils::{maybe, Error};
6
7pub trait SendSpec: maybe::Send {
8    type SendStream: crate::stream::Write
9        + crate::stream::WriteAbort
10        + crate::stream::WriteAborted
11        + crate::stream::Finish;
12}
13
14pub trait RecvSpec: maybe::Send {
15    type RecvStream: crate::stream::Read + crate::stream::ReadAbort;
16}
17
18pub trait PairSpec: maybe::Send + SendSpec + RecvSpec {}
19
20impl<T> PairSpec for T where T: maybe::Send + SendSpec + RecvSpec {}
21
22pub type TupleFor<T> = (<T as SendSpec>::SendStream, <T as RecvSpec>::RecvStream);
23
24pub trait OpeningBi: maybe::Send {
25    type Streams: PairSpec;
26    type Error: Error + maybe::Send + maybe::Sync + 'static;
27
28    fn wait_bi(
29        self,
30    ) -> impl Future<Output = Result<TupleFor<Self::Streams>, Self::Error>> + maybe::Send;
31}
32
33pub trait OpenBi: PairSpec {
34    type Opening: OpeningBi<Streams = Self>;
35    type Error: Error + maybe::Send + maybe::Sync + 'static;
36
37    fn open_bi(&self) -> impl Future<Output = Result<Self::Opening, Self::Error>> + maybe::Send;
38}
39
40pub trait AcceptBi: PairSpec {
41    type Error: Error + maybe::Send + maybe::Sync + 'static;
42
43    fn accept_bi(&self) -> impl Future<Output = Result<TupleFor<Self>, Self::Error>> + maybe::Send;
44}
45
46pub trait OpeningUni: maybe::Send {
47    type Streams: SendSpec;
48    type Error: Error + maybe::Send + maybe::Sync + 'static;
49
50    fn wait_uni(
51        self,
52    ) -> impl Future<Output = Result<<Self::Streams as SendSpec>::SendStream, Self::Error>> + maybe::Send;
53}
54
55pub trait OpenUni: SendSpec {
56    type Opening: OpeningUni<Streams = Self>;
57    type Error: Error + maybe::Send + maybe::Sync + 'static;
58
59    fn open_uni(&self) -> impl Future<Output = Result<Self::Opening, Self::Error>> + maybe::Send;
60}
61
62pub trait AcceptUni: RecvSpec {
63    type Error: Error + maybe::Send + maybe::Sync + 'static;
64
65    fn accept_uni(
66        &self,
67    ) -> impl Future<Output = Result<Self::RecvStream, Self::Error>> + maybe::Send;
68}
xwt_core/session/stream.rs

xwt_core/session/
stream.rs
