From 1f96b5facb1d0462d0e5a83fe77866e5dee3e67c Mon Sep 17 00:00:00 2001 From: Quaternions Date: Thu, 12 Dec 2024 16:53:20 -0800 Subject: [PATCH] validation: incorrect nats assumption --- validation/src/main.rs | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/validation/src/main.rs b/validation/src/main.rs index 63e535f..e504733 100644 --- a/validation/src/main.rs +++ b/validation/src/main.rs @@ -49,9 +49,7 @@ async fn main()->Result<(),StartupError>{ let (publish_new,publish_fix,validator)=tokio::try_join!( publish_new::Publisher::new(stream.clone(),cookie_context.clone(),api.clone(),maps_grpc), publish_fix::Publisher::new(stream.clone(),cookie_context.clone(),api.clone()), - // clone nats here because it's dropped within the function scope, - // meanining the last reference is dropped... - validator::Validator::new(stream.clone(),cookie_context,api) + validator::Validator::new(stream,cookie_context,api) ).map_err(StartupError::NatsStartup)?; // nats consumer threads