From 7cd79209621a972454b6484f7b24c3f946c1f740 Mon Sep 17 00:00:00 2001 From: Devdutt Shenoi Date: Sat, 7 Oct 2023 21:50:09 +0530 Subject: [PATCH] test: fix topic missing from config --- uplink/src/base/serializer/mod.rs | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/uplink/src/base/serializer/mod.rs b/uplink/src/base/serializer/mod.rs index 03e0f7f05..f73f8cbe2 100644 --- a/uplink/src/base/serializer/mod.rs +++ b/uplink/src/base/serializer/mod.rs @@ -987,12 +987,13 @@ mod test { let config = Arc::new(default_config()); let (mut serializer, data_tx, net_rx) = defaults(config); - let stream_config = Arc::new(Default::default()); + let stream_config = + Arc::new(StreamConfig { topic: "hello/world".to_string(), ..Default::default() }); let mut storage = serializer .storage_handler .map - .entry(stream_config) - .or_insert(Storage::new(stream_config, 1024)); + .entry(stream_config.to_owned()) + .or_insert(Storage::new(&stream_config.topic, 1024)); let mut collector = MockCollector::new(data_tx); // Run a collector practically once @@ -1039,12 +1040,13 @@ mod test { let config = Arc::new(default_config()); let (mut serializer, data_tx, _) = defaults(config); - let stream_config = Arc::new(Default::default()); + let stream_config = + Arc::new(StreamConfig { topic: "hello/world".to_string(), ..Default::default() }); let mut storage = serializer .storage_handler .map - .entry(stream_config) - .or_insert(Storage::new(stream_config, 1024)); + .entry(stream_config.to_owned()) + .or_insert(Storage::new(&stream_config.topic, 1024)); let mut collector = MockCollector::new(data_tx); // Run a collector