Mirrors/asciinema
1
0
Fork 0
mirror of https://github.com/asciinema/asciinema.git synced 2025-12-15 19:28:00 +01:00
Code Issues Packages Projects Releases Wiki Activity

Use bounded channel in Stream, just in case

Browse Source
This commit is contained in:
Marcin Kulik
2025-06-23 17:23:06 +02:00
parent aabfee1398
commit 8f01e17dc7
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/stream.rs
View File

@@ -38,7 +38,7 @@ pub enum Event {
#[derive(Clone)] #[derive(Clone)]
pub struct Subscriber(mpsc::Sender<Request>); pub struct Subscriber(mpsc::Sender<Request>);
pub struct LiveStream(mpsc::UnboundedSender<session::Event>); pub struct LiveStream(mpsc::Sender<session::Event>);
impl Stream { impl Stream {
pub fn new() -> Self { pub fn new() -> Self {
@@ -55,7 +55,7 @@ impl Stream {
} }
pub async fn start(self, metadata: &Metadata) -> LiveStream { pub async fn start(self, metadata: &Metadata) -> LiveStream {
let (stream_tx, stream_rx) = mpsc::unbounded_channel(); let (stream_tx, stream_rx) = mpsc::channel(1024);
let request_rx = self.request_rx; let request_rx = self.request_rx;
tokio::spawn(run( tokio::spawn(run(
@@ -72,7 +72,7 @@ impl Stream {
async fn run( async fn run(
tty_size: TtySize, tty_size: TtySize,
tty_theme: Option<TtyTheme>, tty_theme: Option<TtyTheme>,
mut stream_rx: mpsc::UnboundedReceiver<session::Event>, mut stream_rx: mpsc::Receiver<session::Event>,
mut request_rx: mpsc::Receiver<Request>, mut request_rx: mpsc::Receiver<Request>,
) { ) {
let (broadcast_tx, _) = broadcast::channel(1024); let (broadcast_tx, _) = broadcast::channel(1024);
@@ -179,7 +179,7 @@ fn build_vt(tty_size: TtySize) -> Vt {
#[async_trait] #[async_trait]
impl session::Output for LiveStream { impl session::Output for LiveStream {
async fn event(&mut self, event: session::Event) -> io::Result<()> { async fn event(&mut self, event: session::Event) -> io::Result<()> {
self.0.send(event).map_err(io::Error::other) self.0.send(event).await.map_err(io::Error::other)
} }
async fn flush(&mut self) -> io::Result<()> { async fn flush(&mut self) -> io::Result<()> {