diff --git a/examples/ESP8266-OTA/ESP8266-OTA.ino b/examples/ESP8266-OTA/ESP8266-OTA.ino
index d0d92588..a20cfc87 100644
--- a/examples/ESP8266-OTA/ESP8266-OTA.ino
+++ b/examples/ESP8266-OTA/ESP8266-OTA.ino
@@ -44,7 +44,6 @@ void receive_ota(const MQTT::Publish& pub) {
 
   Serial.setDebugOutput(true);
   if (ESP.updateSketch(*pub.payload_stream(), size, true, false)) {
-    pub.payload_stream()->stop();
     Serial.println("Clearing retained message.");
     client.publish(MQTT::Publish(pub.topic(), "")
                    .set_retain());