summaryrefslogtreecommitdiff
path: root/cli/npm/registry.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/npm/registry.rs')
-rw-r--r--cli/npm/registry.rs15
1 files changed, 1 insertions, 14 deletions
diff --git a/cli/npm/registry.rs b/cli/npm/registry.rs
index ec0647023..e960d926f 100644
--- a/cli/npm/registry.rs
+++ b/cli/npm/registry.rs
@@ -29,9 +29,7 @@ use crate::http_util::HttpClient;
use crate::util::fs::atomic_write_file;
use crate::util::progress_bar::ProgressBar;
use crate::util::sync::AtomicFlag;
-use crate::util::sync::TaskQueue;
-use super::cache::should_sync_download;
use super::cache::NpmCache;
static NPM_REGISTRY_DEFAULT_URL: Lazy<Url> = Lazy::new(|| {
@@ -106,24 +104,13 @@ impl CliNpmRegistryApi {
}
}
-static SYNC_DOWNLOAD_TASK_QUEUE: Lazy<TaskQueue> =
- Lazy::new(TaskQueue::default);
-
#[async_trait]
impl NpmRegistryApi for CliNpmRegistryApi {
async fn package_info(
&self,
name: &str,
) -> Result<Arc<NpmPackageInfo>, NpmRegistryPackageInfoLoadError> {
- let result = if should_sync_download() {
- let inner = self.inner().clone();
- SYNC_DOWNLOAD_TASK_QUEUE
- .run(async move { inner.maybe_package_info(name).await })
- .await
- } else {
- self.inner().maybe_package_info(name).await
- };
- match result {
+ match self.inner().maybe_package_info(name).await {
Ok(Some(info)) => Ok(info),
Ok(None) => Err(NpmRegistryPackageInfoLoadError::PackageNotExists {
package_name: name.to_string(),