diff --git a/rtmp/chunk.go b/rtmp/chunk.go
index 52bf060..5784ad5 100644
--- a/rtmp/chunk.go
+++ b/rtmp/chunk.go
@@ -1,6 +1,7 @@
 package rtmp
 
 import (
+	"io"
 	"net"
 	"time"
 	"encoding/binary"
@@ -225,7 +226,7 @@ func read_chunk_data(conn net.Conn, msg_ptr *Message, chnk_size uint32) (uint32,
 	} else {
 		buffer_end = chnk_size + msg_ptr.curr_bytes_read
 	}
-	n, err := conn.Read(msg_ptr.data[msg_ptr.curr_bytes_read:buffer_end])
+	n, err := io.ReadFull(conn, msg_ptr.data[msg_ptr.curr_bytes_read:buffer_end])
 	if err != nil {
 		return 0, err
 	}