We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c45a672 commit fe1e559Copy full SHA for fe1e559
1 file changed
examples/tokio-mqtt-connector-demo/src/main.rs
@@ -146,8 +146,8 @@ async fn main() -> DbResult<()> {
146
147
let runtime = Arc::new(TokioAdapter::new()?);
148
149
- let broker_url = std::env::var("MQTT_BROKER_URL")
150
- .unwrap_or_else(|_| "mqtt://localhost:1883".to_string());
+ let broker_url =
+ std::env::var("MQTT_BROKER_URL").unwrap_or_else(|_| "mqtt://localhost:1883".to_string());
151
152
println!("MQTT Connector Demo");
153
println!("===================");
0 commit comments