Split package changes watcher into an event processing loop and a cha…

…nge mapper loop

Cargo.toml

@@ -2,56 +2,56 @@
 resolver = "2"
 
 members = [
-  "crates/node-file-trace",
-  "crates/tower-uds",
-  "crates/turbo-tasks*",
-  "crates/turbopack*",
-  "crates/turborepo*",
-  "packages/turbo-repository/rust",
-  "xtask",
+    "crates/node-file-trace",
+    "crates/tower-uds",
+    "crates/turbo-tasks*",
+    "crates/turbopack*",
+    "crates/turborepo*",
+    "packages/turbo-repository/rust",
+    "xtask",
 ]
 
 default-members = [
-  "crates/node-file-trace",
-  "crates/turbo-tasks",
-  "crates/turbo-tasks-auto-hash-map",
-  "crates/turbo-tasks-build",
-  "crates/turbo-tasks-bytes",
-  "crates/turbo-tasks-env",
-  "crates/turbo-tasks-fetch",
-  "crates/turbo-tasks-fs",
-  "crates/turbo-tasks-hash",
-  "crates/turbo-tasks-macros-shared",
-  "crates/turbo-tasks-macros-tests",
-  "crates/turbo-tasks-malloc",
-  "crates/turbo-tasks-memory",
-  "crates/turbo-tasks-signposter",
-  "crates/turbo-tasks-signposter-sys",
-  "crates/turbo-tasks-testing",
-  "crates/turbo-tasks-tracing-signpost",
-  "crates/turbopack",
-  "crates/turbopack-bench",
-  "crates/turbopack-cli-utils",
-  "crates/turbopack-core",
-  "crates/turbopack-create-test-app",
-  "crates/turbopack-css",
-  "crates/turbopack-browser",
-  "crates/turbopack-dev-server",
-  "crates/turbopack-ecmascript",
-  "crates/turbopack-env",
-  "crates/turbopack-json",
-  "crates/turbopack-mdx",
-  "crates/turbopack-node",
-  "crates/turbopack-resolve",
-  "crates/turbopack-static",
-  "crates/turbopack-swc-ast-explorer",
-  "crates/turbopack-swc-utils",
-  "crates/turbopack-test-utils",
-  "crates/turbopack-tests",
-  "crates/turbopack-trace-server",
-  "crates/turbopack-trace-utils",
-  "crates/turbopack-wasm",
-  "xtask",
+    "crates/node-file-trace",
+    "crates/turbo-tasks",
+    "crates/turbo-tasks-auto-hash-map",
+    "crates/turbo-tasks-build",
+    "crates/turbo-tasks-bytes",
+    "crates/turbo-tasks-env",
+    "crates/turbo-tasks-fetch",
+    "crates/turbo-tasks-fs",
+    "crates/turbo-tasks-hash",
+    "crates/turbo-tasks-macros-shared",
+    "crates/turbo-tasks-macros-tests",
+    "crates/turbo-tasks-malloc",
+    "crates/turbo-tasks-memory",
+    "crates/turbo-tasks-signposter",
+    "crates/turbo-tasks-signposter-sys",
+    "crates/turbo-tasks-testing",
+    "crates/turbo-tasks-tracing-signpost",
+    "crates/turbopack",
+    "crates/turbopack-bench",
+    "crates/turbopack-cli-utils",
+    "crates/turbopack-core",
+    "crates/turbopack-create-test-app",
+    "crates/turbopack-css",
+    "crates/turbopack-browser",
+    "crates/turbopack-dev-server",
+    "crates/turbopack-ecmascript",
+    "crates/turbopack-env",
+    "crates/turbopack-json",
+    "crates/turbopack-mdx",
+    "crates/turbopack-node",
+    "crates/turbopack-resolve",
+    "crates/turbopack-static",
+    "crates/turbopack-swc-ast-explorer",
+    "crates/turbopack-swc-utils",
+    "crates/turbopack-test-utils",
+    "crates/turbopack-tests",
+    "crates/turbopack-trace-server",
+    "crates/turbopack-trace-utils",
+    "crates/turbopack-wasm",
+    "xtask",
 ]
 
 [workspace.metadata.groups]
@@ -60,18 +60,18 @@ default-members = [
 turborepo-libraries = ["path:crates/turborepo-*"]
 turborepo = ["path:crates/turborepo*"]
 turbopack = [
-  "path:crates/turbopack*",
-  "path:crates/turbo-tasks*",
-  "path:crates/node-file-trace",
+    "path:crates/turbopack*",
+    "path:crates/turbo-tasks*",
+    "path:crates/node-file-trace",
 ]
 
 # List of the packages can be compiled against wasm32-wasi target.
 turbopack-wasi = [
-  "path:crates/turbo-tasks-auto-hash-map",
-  "path:crates/turbo-tasks-hash",
-  "path:crates/turbo-tasks-macro",
-  "path:crates/turbo-tasks-macros-shared",
-  "path:crates/turbo-tasks-build",
+    "path:crates/turbo-tasks-auto-hash-map",
+    "path:crates/turbo-tasks-hash",
+    "path:crates/turbo-tasks-macro",
+    "path:crates/turbo-tasks-macros-shared",
+    "path:crates/turbo-tasks-build",
 ]
 
 [workspace.lints.clippy]
@@ -108,8 +108,8 @@ modularize_imports = { version = "0.68.9" }
 styled_components = { version = "0.96.8" }
 styled_jsx = { version = "0.73.13" }
 swc_core = { version = "0.90.33", features = [
-  "ecma_loader_lru",
-  "ecma_loader_parking_lot",
+    "ecma_loader_lru",
+    "ecma_loader_parking_lot",
 ] }
 swc_emotion = { version = "0.72.8" }
 swc_relay = { version = "0.44.8" }
@@ -189,7 +189,7 @@ turborepo-vt100 = { path = "crates/turborepo-vt100" }
 reqwest = { version = "=0.11.17", default-features = false }
 
 chromiumoxide = { version = "0.5.0", features = [
-  "tokio-runtime",
+    "tokio-runtime",
 ], default-features = false }
 # For matching on errors from chromiumoxide. Keep in
 # sync with chromiumoxide's tungstenite requirement.
@@ -198,8 +198,8 @@ tungstenite = "0.18.0"
 anyhow = "1.0.69"
 assert_cmd = "2.0.8"
 async-compression = { version = "0.3.13", default-features = false, features = [
-  "gzip",
-  "tokio",
+    "gzip",
+    "tokio",
 ] }
 async-trait = "0.1.64"
 atty = "0.2.14"
@@ -235,9 +235,9 @@ indoc = "2.0.0"
 itertools = "0.10.5"
 lazy_static = "1.4.0"
 lightningcss = { version = "1.0.0-alpha.50", features = [
-  "serde",
-  "visitor",
-  "into_owned",
+    "serde",
+    "visitor",
+    "into_owned",
 ] }
 mime = "0.3.16"
 nohash-hasher = "0.2.0"
@@ -259,6 +259,7 @@ pretty_assertions = "1.3.0"
 proc-macro2 = "1.0.79"
 qstring = "0.7.2"
 quote = "1.0.23"
+radix_trie = "0.2.1"
 rand = "0.8.5"
 ratatui = "0.26.1"
 regex = "1.7.0"
@@ -272,10 +273,10 @@ serde_with = "2.3.2"
 serde_yaml = "0.9.17"
 sha2 = "0.10.6"
 smallvec = { version = "1.13.1", features = [
-  "serde",
-  "const_generics",
-  "union",
-  "const_new",
+    "serde",
+    "const_generics",
+    "union",
+    "const_new",
 ] }
 sourcemap = "8.0.1"
 syn = "1.0.107"

crates/turborepo-filewatch/Cargo.toml

@@ -14,7 +14,7 @@ futures = { version = "0.3.26" }
 itertools = { workspace = true }
 nibble_vec = "0.1.0"
 notify = { workspace = true }
-radix_trie = "0.2.1"
+radix_trie = { workspace = true }
 thiserror = "1.0.38"
 tokio = { workspace = true, features = ["full", "time"] }
 tracing = "0.1.37"

crates/turborepo-lib/Cargo.toml

@@ -81,6 +81,7 @@ pprof = { version = "0.12.1", features = [
   "frame-pointer",
 ], optional = true }
 prost = "0.12.3"
+radix_trie = { workspace = true }
 rand = { workspace = true }
 rayon = "1.7.0"
 regex.workspace = true