Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: adjust code to `cache_loader_async` 0.1.2

pull/24376/head
Marco Neumann 2021-10-11 17:12:08 +02:00
parent 49c63d35b1
commit ad41b74a03
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
grpc-router/src/connection_manager.rs
View File

@ -190,7 +190,7 @@ where
/// Builds a [`CachingConnectionManager`].
pub fn build(self) -> CachingConnectionManager<T> {
let make_client = self.make_client;
let (cache, _) = LoadingCache::with_backing(self.backing, move |connect| async move {
let cache = LoadingCache::with_backing(self.backing, move |connect| async move {
(make_client)(connect)
.await
.map_err(|e| Arc::new(Box::new(e) as _))

2
server/src/connection.rs
View File

@ -57,7 +57,7 @@ pub enum CacheFillError {
impl ConnectionManagerImpl {
pub fn new() -> Self {
let (cache, _) = LoadingCache::new(Self::cached_remote_server);
let cache = LoadingCache::new(Self::cached_remote_server);
Self { cache }
}