@@ -88,19 +88,19 @@ func Decode(dst, src []byte) (ndst int) {
8888 return
8989}
9090
91- //Decoder wrap decode for stream reader
91+ // Decoder wrap decode for stream reader
9292type Decoder struct {
9393 wrapped io.Reader
94- srcbuf [20480 ]byte
95- dstbuf [20480 ]byte
94+ srcbuf [2048000 ]byte
95+ dstbuf [2048000 ]byte
9696 src []byte
9797 dst []byte
9898 //we did not record error, is that ok?
9999}
100100
101101const maxCharsOneLine = 72
102102
103- //NewDecoder return Decoder which wrap Decode for stream reader
103+ // NewDecoder return Decoder which wrap Decode for stream reader
104104func NewDecoder (r io.Reader ) * Decoder {
105105 return & Decoder {wrapped : & eatLastNewLineReader {wrapped : newLineReader (r , maxCharsOneLine )}}
106106}
@@ -138,7 +138,7 @@ func (d *Decoder) Read(p []byte) (nRead int, err error) {
138138 }
139139}
140140
141- //ReadRaw only read from wrapped io without Decoding
141+ // ReadRaw only read from wrapped io without Decoding
142142func (d * Decoder ) ReadRaw (p []byte ) (nRead int , err error ) {
143143 nRead , err = d .wrapped .Read (p )
144144 return
@@ -159,9 +159,9 @@ func (r *eatLastNewLineReader) Read(p []byte) (nRead int, err error) {
159159 return
160160}
161161
162- //numCharsLineReader Read
163- //implement continue read if size of line eq numChars, until
164- //size of line less than numChars
162+ // numCharsLineReader Read
163+ // implement continue read if size of line eq numChars, until
164+ // size of line less than numChars
165165type numCharsLineReader struct {
166166 wrapped bufio.Reader
167167 numChars int //number of each line
0 commit comments