Merge pull request #399 from zed-industries/unbounded-fs-events

Buffer all incoming file-system events
This commit is contained in:
Antonio Scandurra 2022-02-04 16:48:07 +01:00 committed by GitHub
commit ed37ad37fb
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -115,7 +115,7 @@ impl Fs for RealFs {
path: &Path,
latency: Duration,
) -> Pin<Box<dyn Send + Stream<Item = Vec<fsevent::Event>>>> {
let (mut tx, rx) = postage::mpsc::channel(64);
let (tx, rx) = smol::channel::unbounded();
let (stream, handle) = EventStream::new(&[path], latency);
std::mem::forget(handle);
std::thread::spawn(move || {