diff --git a/eden/scm/lib/edenapi/src/response.rs b/eden/scm/lib/edenapi/src/response.rs index 7693258658..500093dca6 100644 --- a/eden/scm/lib/edenapi/src/response.rs +++ b/eden/scm/lib/edenapi/src/response.rs @@ -23,7 +23,7 @@ pub struct BlockingResponse { } impl BlockingResponse { - pub(crate) fn from_async(fetch: F) -> Result + pub fn from_async(fetch: F) -> Result where F: Future, EdenApiError>>, { diff --git a/eden/scm/lib/revisionstore/src/edenapi/mod.rs b/eden/scm/lib/revisionstore/src/edenapi/mod.rs index 38405899fd..52e59b046b 100644 --- a/eden/scm/lib/revisionstore/src/edenapi/mod.rs +++ b/eden/scm/lib/revisionstore/src/edenapi/mod.rs @@ -10,7 +10,7 @@ use std::sync::Arc; use async_trait::async_trait; -use edenapi::{BlockingResponse, EdenApi, EdenApiBlocking, EdenApiError, Response}; +use edenapi::{BlockingResponse, EdenApi, EdenApiError, Response}; use edenapi_types::{EdenApiServerError, FileEntry, FileSpec, TreeAttributes, TreeEntry}; use progress::{NullProgressFactory, ProgressFactory}; use types::Key; @@ -126,14 +126,14 @@ impl EdenApiFileStore { &self, keys: Vec, ) -> Result, EdenApiError> { - self.client.files_blocking(self.repo.clone(), keys) + BlockingResponse::from_async(self.client.files(self.repo.clone(), keys)) } pub fn files_attrs_blocking( &self, reqs: Vec, ) -> Result, EdenApiError> { - self.client.files_attrs_blocking(self.repo.clone(), reqs) + BlockingResponse::from_async(self.client.files_attrs(self.repo.clone(), reqs)) } } @@ -143,8 +143,7 @@ impl EdenApiTreeStore { keys: Vec, attributes: Option, ) -> Result>, EdenApiError> { - self.client - .trees_blocking(self.repo.clone(), keys, attributes) + BlockingResponse::from_async(self.client.trees(self.repo.clone(), keys, attributes)) } }