Return errors from the loop in connect() rather than breaking.

rtmp/rtmp.go

@@ -192,14 +192,14 @@ func connect(c *Conn) error {
 		c.log(WarnLevel, pkg+"sendConnect failed", "error", err.Error())
 		return err
 	}
-	c.log(DebugLevel, pkg+"negotiating")
 
+	c.log(DebugLevel, pkg+"negotiating")
 	var buf [256]byte
 	for !c.isPlaying {
 		pkt := packet{buf: buf[:]}
 		err = pkt.readFrom(c)
 		if err != nil {
-			break
+			return err
 		}
 
 		switch pkt.packetType {
@@ -208,14 +208,10 @@ func connect(c *Conn) error {
 		default:
 			err = handlePacket(c, &pkt)
 			if err != nil {
-				break
-			}
-		}
-	}
-
-	if !c.isPlaying {
 				return err
 			}
+		}
+	}
 	return nil
 }