Dreaded_X/pico_p1
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Also load MQTT port from environment

Browse Source
This commit is contained in:
Dreaded_X 2023-08-28 02:41:40 +02:00
parent 5f70015e0c
commit 2a436071bf
Signed by: Dreaded_X
GPG Key ID: FA5F485356B0D2D4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main.rs
View File

@ -12,7 +12,7 @@ use embassy_futures::{
select::{select, Either},
yield_now,
};
use embassy_net::{tcp::TcpSocket, Config, Ipv4Address, Stack, StackResources};
use embassy_net::{tcp::TcpSocket, Config, IpEndpoint, Stack, StackResources};
use embassy_rp::{
bind_interrupts,
clocks::RoscRng,
@ -212,7 +212,7 @@ async fn main(spawner: Spawner) {
let mut socket = TcpSocket::new(stack, &mut rx_buffer, &mut tx_buffer);
// socket.set_timeout(Some(Duration::from_secs(10)));
let addr = (Ipv4Address::from_str(env!("MQTT_IP")).unwrap(), 1883);
let addr = IpEndpoint::from_str(env!("MQTT_ADDRESS")).unwrap();
while let Err(e) = socket.connect(addr).await {
warn!("Connect error: {:?}", e);