murgamu 0.7.4

A NestJS-inspired web framework for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use tokio::sync::mpsc;
pub struct MurSseChannel;
use super::MurSseReceiver;
use super::MurSseSender;

impl MurSseChannel {
	pub fn new_channel(buffer_size: usize) -> (MurSseSender, MurSseReceiver) {
		let (tx, rx) = mpsc::channel(buffer_size);
		(MurSseSender { tx }, MurSseReceiver { rx })
	}

	pub fn default_channel() -> (MurSseSender, MurSseReceiver) {
		Self::new_channel(256)
	}
}