diff --git a/src/v3/client/dispatcher.rs b/src/v3/client/dispatcher.rs
index 6124b466..1214ca18 100644
--- a/src/v3/client/dispatcher.rs
+++ b/src/v3/client/dispatcher.rs
@@ -235,7 +235,7 @@ where
                     this.inner.control.call(ControlMessage::publish(pkt.into_inner())),
                     &*this.inner,
                 )));
-                return self.poll(cx);
+                self.poll(cx)
             }
         }
     }
diff --git a/src/v3/sink.rs b/src/v3/sink.rs
index 20590056..40ba89c3 100644
--- a/src/v3/sink.rs
+++ b/src/v3/sink.rs
@@ -142,7 +142,7 @@ impl MqttSink {
             log::trace!("Unexpected PublishAck packet");
         }
         self.close();
-        return Err(ProtocolError::PacketIdMismatch);
+        Err(ProtocolError::PacketIdMismatch)
     }
 }