diff --git a/internal/data_channel.go b/internal/data_channel.go
index 46fa8df..a095d5d 100644
--- a/internal/data_channel.go
+++ b/internal/data_channel.go
@@ -1,7 +1,6 @@
 package internal
 
 import (
-	"bufio"
 	"bytes"
 	"encoding/json"
 	"errors"
@@ -14,11 +13,10 @@ import (
 type DataChannel struct {
 	dataChannel *webrtc.DataChannel
 
-	rawDataLock           sync.RWMutex
-	rawDataWriter         *io.PipeWriter
-	rawDataReaderBuffered *bufio.Reader
-	rawDataReader         *io.PipeReader
-	rawDataRest           uint64
+	rawDataLock   sync.RWMutex
+	rawDataWriter *io.PipeWriter
+	rawDataReader *io.PipeReader
+	rawDataRest   uint64
 
 	bufferWaitChannel chan interface{}
 	closeWaitChannel  chan interface{}
@@ -177,7 +175,6 @@ func (conn *DataChannel) ExpectRawData(expectedLength uint64) {
 	defer conn.rawDataLock.Unlock()
 
 	conn.rawDataReader, conn.rawDataWriter = io.Pipe()
-	conn.rawDataReaderBuffered = bufio.NewReaderSize(conn.rawDataReader, 16*1024*1024)
 	conn.rawDataRest = expectedLength
 }
 
@@ -199,12 +196,12 @@ func (conn *DataChannel) SendMessage(msg *Message) (err error) {
 }
 
 func (conn *DataChannel) Read(p []byte) (n int, err error) {
-	if conn.rawDataReaderBuffered == nil {
+	if conn.rawDataReader == nil {
 		err = errors.New("Unexpected raw data read")
 		return
 	}
 
-	n, err = conn.rawDataReaderBuffered.Read(p)
+	n, err = conn.rawDataReader.Read(p)
 	return
 }