We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 23b2aaf commit 7ab6f9dCopy full SHA for 7ab6f9d
1 file changed
src/mqtt_client/engine.rs
@@ -998,13 +998,13 @@ impl QuicMqttEngine {
998
quinn_proto::Event::Stream(_stream_id) => {
999
// Stream event (readable/writable etc)
1000
}
1001
- quinn_proto::Event::Connected => {
+ quinn_proto::Event::Connected
1002
// QUIC Handshake done. Open a bidirectional stream for MQTT.
1003
- if self.mqtt_stream.is_none() {
1004
- if let Some(stream_id) = conn.streams().open(quinn_proto::Dir::Bi) {
1005
- self.mqtt_stream = Some(stream_id);
1006
- self.mqtt_engine.connect();
1007
- }
+ if self.mqtt_stream.is_none() =>
+ {
+ if let Some(stream_id) = conn.streams().open(quinn_proto::Dir::Bi) {
+ self.mqtt_stream = Some(stream_id);
+ self.mqtt_engine.connect();
1008
1009
1010
quinn_proto::Event::ConnectionLost { .. } => {
0 commit comments