From 27f908b7682c8a5a6ea244fa63902663b4d6446a Mon Sep 17 00:00:00 2001 From: Oliver Thallmair Date: Mon, 17 Feb 2025 09:54:20 +0100 Subject: [PATCH] cargo fmt --- subscription-cache/src/lib.rs | 2 +- up-streamer/tests/usubscription.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/subscription-cache/src/lib.rs b/subscription-cache/src/lib.rs index 7fdc9bc..e8cee60 100644 --- a/subscription-cache/src/lib.rs +++ b/subscription-cache/src/lib.rs @@ -11,10 +11,10 @@ * SPDX-License-Identifier: Apache-2.0 ********************************************************************************/ +use log::warn; use std::collections::{HashMap, HashSet}; use std::hash::{Hash, Hasher}; use std::sync::Mutex; -use log::warn; use up_rust::core::usubscription::{ EventDeliveryConfig, FetchSubscriptionsResponse, SubscribeAttributes, SubscriberInfo, SubscriptionStatus, diff --git a/up-streamer/tests/usubscription.rs b/up-streamer/tests/usubscription.rs index e0516c6..9a01feb 100644 --- a/up-streamer/tests/usubscription.rs +++ b/up-streamer/tests/usubscription.rs @@ -20,7 +20,7 @@ use usubscription_static_file::USubscriptionStaticFile; #[tokio::test(flavor = "multi_thread")] async fn usubscription_bad_data() { integration_test_utils::init_logging(); - + let utransport_foo: Arc = Arc::new(UPClientFailingRegister::new("upclient_foo").await); let utransport_bar: Arc =