fn subscribe(&mut self) -> Result<(), ()> {
        // Note(unwrap): We ensure that this storage is always sufficiently large to store
        // the wildcard post-fix for MQTT.
        let mut prefix: String<{ MAX_TOPIC_LENGTH + 2 }> = String::from(self.prefix.as_str());
        prefix.push_str("/#").unwrap();

        self.mqtt.client.subscribe(&prefix, &[]).map_err(|_| ())
    }
/// Guard to handle subscription to the command prefix.
///
/// # Returns
/// Error if the command prefix has not yet been subscribed to.
Guard to handle subscription to the command prefix.
Guard to handle subscription to the command prefix .
fn subscribe(&mut self) -> Result<(), ()> {
        // Note(unwrap): We ensure that this storage is always sufficiently large to store
        // the wildcard post-fix for MQTT.
        let mut prefix: String<{ MAX_TOPIC_LENGTH + 2 }> = String::from(self.prefix.as_str());
        prefix.push_str("/#").unwrap();
        self.mqtt.client.subscribe(&prefix, &[]).map_err(|_| ())
    }
fn subscribe ( & mut self ) -> Result < ( ) , ( ) > { // Note(unwrap): We ensure that this storage is always sufficiently large to store // the wildcard post-fix for MQTT. let mut prefix : String < { MAX_TOPIC_LENGTH + 2 } > = String :: from ( self . prefix . as_str ( ) ) ; prefix . push_str ( " " ) . unwrap ( ) ; self . mqtt . client . subscribe ( & prefix , & [ ] ) . map_err ( | _ | ( ) ) }
Guard to handle subscription to the command prefix.
Guard to handle subscription to the command prefix .
&mut self
Error if the command prefix has not yet been subscribed to.
Error if the command prefix has not yet been subscribed to .
&mut self