We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 925f900 commit d70fd14Copy full SHA for d70fd14
up-subscription-cli/src/main.rs
@@ -183,7 +183,6 @@ async fn main() {
183
info!(
184
"Usubscription service running and listeners up on {}",
185
_config.get_source_uri()
186
-
187
);
188
189
// Daemonize or wait for shutdown signal
up-subscription-cli/src/transport/mqtt5.rs
@@ -20,10 +20,9 @@ pub(crate) async fn get_mqtt5_transport(
20
uri_provider: Arc<dyn LocalUriProvider>,
21
mqtt5_args: Mqtt5TransportOptions,
22
) -> Result<Arc<dyn UTransport>, UStatus> {
23
- Ok(Mqtt5Transport::new(
24
- mqtt5_args,
25
- uri_provider.get_authority(),
+ Ok(
+ Mqtt5Transport::new(mqtt5_args, uri_provider.get_authority())
+ .await
26
+ .map(Arc::new)?,
27
)
- .await
28
- .map(Arc::new)?)
29
}
0 commit comments