StrafesNET/maps-service
7
Fork 0
Code Issues 7 Pull Requests Packages Projects Releases Wiki Activity

validation: incorrect nats assumption

Browse Source
This commit is contained in:
Quaternions 2024-12-12 16:53:20 -08:00
parent 22086e772c
commit 1f96b5facb
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
validation/src/main.rs
View File

@ -49,9 +49,7 @@ async fn main()->Result<(),StartupError>{
let (publish_new,publish_fix,validator)=tokio::try_join!( let (publish_new,publish_fix,validator)=tokio::try_join!(
publish_new::Publisher::new(stream.clone(),cookie_context.clone(),api.clone(),maps_grpc), publish_new::Publisher::new(stream.clone(),cookie_context.clone(),api.clone(),maps_grpc),
publish_fix::Publisher::new(stream.clone(),cookie_context.clone(),api.clone()), publish_fix::Publisher::new(stream.clone(),cookie_context.clone(),api.clone()),
// clone nats here because it's dropped within the function scope, validator::Validator::new(stream,cookie_context,api)
// meanining the last reference is dropped...
validator::Validator::new(stream.clone(),cookie_context,api)
).map_err(StartupError::NatsStartup)?; ).map_err(StartupError::NatsStartup)?;
// nats consumer threads // nats consumer threads