diff --git a/src/swqos/blockrazor.rs b/src/swqos/blockrazor.rs index f57ee63..87d4a59 100644 --- a/src/swqos/blockrazor.rs +++ b/src/swqos/blockrazor.rs @@ -86,7 +86,7 @@ pub enum BlockRazorBackend { Grpc { endpoint: String, auth_token: String, - grpc_client: ArcSwap, + grpc_client: Arc>, ping_handle: Arc>>>, stop_ping: Arc, }, @@ -158,7 +158,10 @@ impl BlockRazorClient { .await .map_err(|e| anyhow::anyhow!("Failed to connect to gRPC endpoint: {}", e))?; - let grpc_client = ArcSwap::from_pointee(BlockRazorGrpcClient::new(channel, auth_token.clone())); + let grpc_client = Arc::new(ArcSwap::from_pointee(BlockRazorGrpcClient::new( + channel, + auth_token.clone(), + ))); let ping_handle = Arc::new(tokio::sync::Mutex::new(None)); let stop_ping = Arc::new(AtomicBool::new(false));