This repository was archived by the owner on Jan 17, 2020. It is now read-only.

Description
I'm hitting unimplemented!() in this function, in src/client/mqttstate.rs (line 71):
pub fn handle_outgoing_mqtt_packet(&mut self, packet: Packet) -> Result<Request, NetworkError> {
let out = match packet {
Packet::Publish(publish) => {
let publish = self.handle_outgoing_publish(publish)?;
Request::Publish(publish)
}
Packet::Pingreq => self.handle_outgoing_ping()?,
Packet::Subscribe(subs) => {
let subscription = self.handle_outgoing_subscribe(subs)?;
Request::Subscribe(subscription)
}
_ => unimplemented!(),
};
... right when unsubscribing/resubscribing a topic.