From 54d40e008a0905a28569dbeb6f12a1a02189c217 Mon Sep 17 00:00:00 2001 From: David Sherret Date: Mon, 19 Dec 2022 20:22:17 -0500 Subject: perf(lsp): concurrent reads and exclusive writes (#17135) --- cli/npm/resolvers/global.rs | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) (limited to 'cli/npm/resolvers/global.rs') diff --git a/cli/npm/resolvers/global.rs b/cli/npm/resolvers/global.rs index 093e15ded..b005cbaeb 100644 --- a/cli/npm/resolvers/global.rs +++ b/cli/npm/resolvers/global.rs @@ -138,11 +138,7 @@ impl InnerNpmPackageResolver for GlobalNpmPackageResolver { packages: Vec, ) -> BoxFuture<'static, Result<(), AnyError>> { let resolver = self.clone(); - async move { - resolver.resolution.add_package_reqs(packages).await?; - cache_packages_in_resolver(&resolver).await - } - .boxed() + async move { resolver.resolution.add_package_reqs(packages).await }.boxed() } fn set_package_reqs( @@ -150,11 +146,12 @@ impl InnerNpmPackageResolver for GlobalNpmPackageResolver { packages: HashSet, ) -> BoxFuture<'static, Result<(), AnyError>> { let resolver = self.clone(); - async move { - resolver.resolution.set_package_reqs(packages).await?; - cache_packages_in_resolver(&resolver).await - } - .boxed() + async move { resolver.resolution.set_package_reqs(packages).await }.boxed() + } + + fn cache_packages(&self) -> BoxFuture<'static, Result<(), AnyError>> { + let resolver = self.clone(); + async move { cache_packages_in_resolver(&resolver).await }.boxed() } fn ensure_read_permission(&self, path: &Path) -> Result<(), AnyError> { -- cgit v1.2.3