diff --git a/rtmp/connect.go b/rtmp/connect.go index 5f91aee..6eb006a 100644 --- a/rtmp/connect.go +++ b/rtmp/connect.go @@ -5,19 +5,12 @@ import ( ) func NegotiateConnect(chnk_wrp_ptr *ChunkWrapper) (bool) { - fmt.Println(chnk_wrp_ptr.params.peer_chunk_size) if err := chnk_wrp_ptr.ReadPeerChunkSize(); err != nil { return false } - fmt.Println(chnk_wrp_ptr.params.peer_chunk_size) - for { - full_msg_ptr, err := chnk_wrp_ptr.ReadChunk() - if err != nil { - return false - } - if full_msg_ptr == nil { - continue - } - fmt.Println(*full_msg_ptr) + if err := chnk_wrp_ptr.ReadConnectCommand(); err != nil { + return false } + fmt.Println(chnk_wrp_ptr.params) + return false }