Get incoming events only from async client

[maxbull]

I use the AsyncClientMQTT of glazemq to subscribe specific topics. And I only want to handle the requests only because the subscribed topics are concerned only.

I know I cloud use match to deal with Incoming events only, like this:

  loop {
        match eventloop.poll().await {
            Ok(Event::Incoming(MqttPacket::Publish(p))) => {
                    println!("Incoming = {:?}, {:?}", p.topic, p.payload);
            },
            Ok(Event::Incoming(MqttPacket::Resp)) |
            Ok(Event::Outgoing(Outgoing::Req)) => {},
            Ok(Event::Incoming(i)) => {
                println!("Incoming = {:?}", i);
            },
            Ok(Event::Outgoing(o)) => {
                println!("Outgoing = {:?}", o);
            },
            Err(e) => {
                println!("Error = {:?}", e);
                // ERROR: Here I have to subscribe again to the topics :(
                client.subscribe("#", QoS::AtMostOnce).await.unwrap();
            }
        }

However, I'm interesting in way that allows to have solution or method that I can get the incoming events ONLY directly. Thanks

[sigrlami]

Subscriptions are lost on disconnect, the only options currently dump it to the file and attach on re-connect. I'll check if there is a way to create something like a state to ease up this use case.