From 2dbfcfe19fdf9dc78547ab1bcd87d0e7b38e7dab Mon Sep 17 00:00:00 2001
From: dexter <178529795@qq.com>
Date: Mon, 9 May 2022 22:04:11 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8E=A8=E6=B5=81=E9=80=82?=
 =?UTF-8?q?=E9=85=8D=E5=BC=95=E6=93=8E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 client.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/client.go b/client.go
index a761d30..9a29e83 100644
--- a/client.go
+++ b/client.go
@@ -2,6 +2,7 @@ package rtmp
 
 import (
 	"bufio"
+	"errors"
 	"net"
 	"net/url"
 	"strings"
@@ -85,13 +86,13 @@ func (pusher *RTMPPusher) Connect() (err error) {
 	return
 }
 
-func (pusher *RTMPPusher) Push() {
+func (pusher *RTMPPusher) Push() error {
 	pusher.SendMessage(RTMP_MSG_AMF0_COMMAND, &CommandMessage{"createStream", 2})
 	defer pusher.Stop()
 	for {
 		msg, err := pusher.RecvMessage()
 		if err != nil {
-			break
+			return err
 		}
 		switch msg.MessageTypeID {
 		case RTMP_MSG_AMF0_COMMAND:
@@ -118,7 +119,7 @@ func (pusher *RTMPPusher) Push() {
 					if response.Infomation["code"] == NetStream_Publish_Start {
 						go pusher.PlayBlock()
 					} else {
-						return
+						return errors.New(response.Infomation["code"].(string))
 					}
 				}
 			}