Commit c04518b5 authored by wojtekt's avatar wojtekt

Increase limit for object size in streaming serializer

parent f5d6de39
...@@ -64,7 +64,7 @@ func NewDecoder(r io.ReadCloser, d runtime.Decoder) Decoder { ...@@ -64,7 +64,7 @@ func NewDecoder(r io.ReadCloser, d runtime.Decoder) Decoder {
reader: r, reader: r,
decoder: d, decoder: d,
buf: make([]byte, 1024), buf: make([]byte, 1024),
maxBytes: 1024 * 1024, maxBytes: 16 * 1024 * 1024,
} }
} }
......
...@@ -51,7 +51,7 @@ func TestDecoder(t *testing.T) { ...@@ -51,7 +51,7 @@ func TestDecoder(t *testing.T) {
frames := [][]byte{ frames := [][]byte{
make([]byte, 1025), make([]byte, 1025),
make([]byte, 1024*5), make([]byte, 1024*5),
make([]byte, 1024*1024*5), make([]byte, 1024*1024*17),
make([]byte, 1025), make([]byte, 1025),
} }
pr, pw := io.Pipe() pr, pw := io.Pipe()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment