rolldown 0.1.0

Fast JavaScript bundler in Rust, designed for the future of Vite
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

use anyhow::{Context, Result};
use std::sync::Arc;
use tokio::sync::Mutex;

use crate::watch::event::WatcherEvent;

pub type SharedWatcherEmitter = Arc<WatcherEmitter>;

pub struct WatcherEmitter {
  tx: Arc<std::sync::mpsc::Sender<WatcherEvent>>,
  pub rx: Arc<Mutex<std::sync::mpsc::Receiver<WatcherEvent>>>,
}

impl WatcherEmitter {
  pub fn new() -> Self {
    let (tx, rx) = std::sync::mpsc::channel::<WatcherEvent>();
    Self { tx: Arc::new(tx), rx: Arc::new(Mutex::new(rx)) }
  }

  pub fn emit(&self, event: WatcherEvent) -> Result<()> {
    self
      .tx
      .send(event)
      .context("WatcherEmitter: failed to emit event - receiver was dropped prematurely")?;
    Ok(())
  }
}