diff --git a/src/connectors/conn_http_progressive.cpp b/src/connectors/conn_http_progressive.cpp
index 49229f3a..4987a76b 100644
--- a/src/connectors/conn_http_progressive.cpp
+++ b/src/connectors/conn_http_progressive.cpp
@@ -117,7 +117,7 @@ namespace Connector_HTTP {
             continue;
           }
           //wait until we have a header
-          while ( !Strm.metadata){
+          while ( !Strm.metadata && ss.connected()){
             if (ss.spool()){
               Strm.parsePacket(ss.Received()); //read the metadata
             }else{
diff --git a/src/connectors/conn_rtmp.cpp b/src/connectors/conn_rtmp.cpp
index abcb10da..36bb9303 100644
--- a/src/connectors/conn_rtmp.cpp
+++ b/src/connectors/conn_rtmp.cpp
@@ -551,7 +551,7 @@ namespace Connector_RTMP {
           ss.setBlocking(false);
 
           //assure metadata is received
-          while ( !Strm.metadata){
+          while ( !Strm.metadata && ss.connected()){
             if (ss.spool()){
               Strm.parsePacket(ss.Received()); //read the metadata
             }else{