diff --git a/packages/ssestream/ssestream.go b/packages/ssestream/ssestream.go index 81adbd6..cc0afb7 100644 --- a/packages/ssestream/ssestream.go +++ b/packages/ssestream/ssestream.go @@ -29,7 +29,7 @@ func NewDecoder(res *http.Response) Decoder { decoder = t(res.Body) } else { scn := bufio.NewScanner(res.Body) - scn.Buffer(nil, bufio.MaxScanTokenSize<<4) + scn.Buffer(nil, bufio.MaxScanTokenSize<<9) decoder = &eventStreamDecoder{rc: res.Body, scn: scn} } return decoder