mirror of
https://github.com/neondatabase/neon.git
synced 2026-01-08 05:52:55 +00:00
minor code tidy-up
This commit is contained in:
@@ -169,14 +169,7 @@ impl PooledItemFactory<StreamReturner> for StreamFactory {
|
||||
std::collections::HashMap::new(),
|
||||
)),
|
||||
};
|
||||
let map: Arc<
|
||||
tokio::sync::Mutex<
|
||||
std::collections::HashMap<
|
||||
u64,
|
||||
tokio::sync::mpsc::Sender<Result<proto::GetPageResponse, _>>,
|
||||
>,
|
||||
>,
|
||||
> = Arc::clone(&stream_returner.sender_hashmap);
|
||||
let map = Arc::clone(&stream_returner.sender_hashmap);
|
||||
|
||||
tokio::spawn(async move {
|
||||
let map_clone = Arc::clone(&map);
|
||||
|
||||
Reference in New Issue
Block a user