This commit is contained in:
Gregor Reitzenstein 2020-09-17 15:47:41 +02:00
parent f4d5a70841
commit 33d9d76755

View File

@ -63,9 +63,8 @@ impl Stream for Shelly {
if let Some(status) = ready!(Signal::poll_change(Pin::new(s), cx)) { if let Some(status) = ready!(Signal::poll_change(Pin::new(s), cx)) {
let topic = format!("shellies/{}/relay/0/command", unpin.name); let topic = format!("shellies/{}/relay/0/command", unpin.name);
let pl = match status { let pl = match status {
Status::Free => "off", Status::Free | Status::Blocked => "off",
Status::Occupied => "on", Status::Occupied => "on",
Status::Blocked => "off",
}; };
let msg = mqtt::Message::new(topic, pl, 0); let msg = mqtt::Message::new(topic, pl, 0);
let f = unpin.client.publish(msg).map(|_| ()); let f = unpin.client.publish(msg).map(|_| ());