moq-transfork 0.2.0

Media over QUIC
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

use super::{Close, Reader, Writer};
use crate::{message, Error};

pub(super) struct Stream {
	pub writer: Writer,
	pub reader: Reader,
}

impl Stream {
	pub async fn open(session: &mut web_transport::Session, typ: message::Stream) -> Result<Self, Error> {
		let (send, recv) = session.open_bi().await?;

		let mut writer = Writer::new(send);
		let reader = Reader::new(recv);
		writer.encode(&typ).await?;

		Ok(Stream { writer, reader })
	}

	pub async fn accept(session: &mut web_transport::Session) -> Result<Self, Error> {
		let (send, recv) = session.accept_bi().await?;

		let writer = Writer::new(send);
		let reader = Reader::new(recv);

		Ok(Stream { writer, reader })
	}
}

impl Close for Stream {
	fn close(&mut self, err: Error) {
		self.writer.close(err.clone());
		self.reader.close(err);
	}
}