diff --git a/pageserver/client_grpc/src/request_tracker.rs b/pageserver/client_grpc/src/request_tracker.rs index 7a40e6ece7..9cce6a06e1 100644 --- a/pageserver/client_grpc/src/request_tracker.rs +++ b/pageserver/client_grpc/src/request_tracker.rs @@ -36,7 +36,14 @@ use client_cache::PooledItemFactory; #[derive(Clone)] pub struct StreamReturner { sender: tokio::sync::mpsc::Sender, - sender_hashmap: Arc>>>>, + sender_hashmap: Arc< + tokio::sync::Mutex< + std::collections::HashMap< + u64, + tokio::sync::mpsc::Sender>, + >, + >, + >, } pub struct StreamFactory {