diff --git a/client.go b/client.go
index ff11073..a761d30 100644
--- a/client.go
+++ b/client.go
@@ -116,7 +116,7 @@ func (pusher *RTMPPusher) Push() {
 					})
 				} else if response, ok := msg.MsgData.(*ResponsePublishMessage); ok {
 					if response.Infomation["code"] == NetStream_Publish_Start {
-						go pusher.PlayBlock(pusher)
+						go pusher.PlayBlock()
 					} else {
 						return
 					}
diff --git a/server.go b/server.go
index b6f4feb..f4fd024 100644
--- a/server.go
+++ b/server.go
@@ -154,7 +154,7 @@ func (config *RTMPConfig) ServeTCP(conn *net.TCPConn) {
 						sender.Begin()
 						sender.Response(cmd.TransactionId, NetStream_Play_Reset, Level_Status)
 						sender.Response(cmd.TransactionId, NetStream_Play_Start, Level_Status)
-						go sender.PlayBlock(sender)
+						go sender.PlayBlock()
 					}
 				}
 			case RTMP_MSG_AUDIO: