lafere 0.2.0-pre.6

A more or less simple communication protocol library.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use crate::handler::handler::Request;

use tokio::sync::mpsc;

/// A receiver that waits on messages from the handler (client)
#[derive(Debug)]
pub struct Receiver<P> {
	pub(super) inner: mpsc::Receiver<Request<P>>,
}

impl<P> Receiver<P> {
	/// Receive a new message from the client
	pub async fn receive(&mut self) -> Option<Request<P>> {
		self.inner.recv().await
	}

	pub fn is_closed(&self) -> bool {
		self.inner.is_closed()
	}
}